MCPcopy Index your code
hub / github.com/pathwaycom/pathway / _intersect

Method _intersect

python/pathway/internals/table.py:1074–1083  ·  view source on GitHub ↗
(self, *tables: Table)

Source from the content-addressed store, hash-verified

1072
1073 @contextualized_operator
1074 def _intersect(self, *tables: Table) -> Table[TSchema]:
1075 intersecting_ids = (
1076 self._id_column,
1077 *(table._id_column for table in tables),
1078 )
1079 context = clmn.IntersectContext(
1080 intersecting_ids=intersecting_ids,
1081 )
1082
1083 return self._table_with_context(context)
1084
1085 @trace_user_frame
1086 @check_arg_types

Callers 1

intersectMethod · 0.95

Calls 1

_table_with_contextMethod · 0.95

Tested by

no test coverage detected