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

Method _concat

python/pathway/internals/table.py:1670–1687  ·  view source on GitHub ↗
(self, *others: Table[TSchema])

Source from the content-addressed store, hash-verified

1668 @trace_user_frame
1669 @contextualized_operator
1670 def _concat(self, *others: Table[TSchema]) -> Table[TSchema]:
1671 union_ids = (self._id_column, *(other._id_column for other in others))
1672 if not self._get_universe_solver().query_are_disjoint(
1673 *(c.universe for c in union_ids)
1674 ):
1675 raise ValueError(
1676 "Universes of the arguments of Table.concat() have to be disjoint.\n"
1677 + "Consider using Table.promise_universes_are_disjoint() to assert it.\n"
1678 + "(However, untrue assertion might result in runtime errors.)"
1679 )
1680 context = clmn.ConcatUnsafeContext(
1681 union_ids=union_ids,
1682 updates=tuple(
1683 {col_name: other._columns[col_name] for col_name in self.keys()}
1684 for other in others
1685 ),
1686 )
1687 return self._table_with_context(context)
1688
1689 @trace_user_frame
1690 @check_arg_types

Callers 1

concatMethod · 0.80

Calls 5

_get_universe_solverMethod · 0.95
keysMethod · 0.95
_table_with_contextMethod · 0.95
tupleFunction · 0.85
query_are_disjointMethod · 0.80

Tested by

no test coverage detected