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

Method _copy_input_table

python/pathway/internals/operator.py:428–435  ·  view source on GitHub ↗
(self, name: str, table: tables.Table, unique: bool)

Source from the content-addressed store, hash-verified

426 return output.to_output()
427
428 def _copy_input_table(self, name: str, table: tables.Table, unique: bool):
429 if unique:
430 universe = Universe()
431 else:
432 universe = self._universe_mapping[table._universe]
433 table_copy = table._materialize(universe)
434 table_copy._set_source(OutputHandle(self, name, table_copy))
435 return table_copy
436
437 def hard_table_dependencies(self) -> StableSet[tables.Table]:
438 return self.input_tables

Callers 1

__call__Method · 0.95

Calls 4

UniverseClass · 0.90
OutputHandleClass · 0.85
_materializeMethod · 0.80
_set_sourceMethod · 0.80

Tested by

no test coverage detected