MCPcopy Create free account
hub / github.com/pathwaycom/pathway / __init__

Method __init__

python/pathway/internals/table.py:112–126  ·  view source on GitHub ↗
(
        self,
        _columns: Mapping[str, clmn.Column],
        _context: clmn.Context,
        _schema: type[Schema] | None = None,
    )

Source from the content-addressed store, hash-verified

110 """Lateinit by operator."""
111
112 def __init__(
113 self,
114 _columns: Mapping[str, clmn.Column],
115 _context: clmn.Context,
116 _schema: type[Schema] | None = None,
117 ):
118 if _schema is None:
119 _schema = schema_from_columns(_columns, _context.id_column)
120 super().__init__(_context)
121 self._columns = dict(_columns)
122 self._schema = _schema
123 self._id_column = _context.id_column
124 assert dt.wrap(self._id_column.dtype) == dt.wrap(self._schema.id_type)
125 self._substitution = {thisclass.this: self}
126 self._rowwise_context = clmn.RowwiseContext(self._id_column)
127
128 @property
129 def id(self) -> expr.ColumnReference:

Callers

nothing calls this directly

Calls 2

schema_from_columnsFunction · 0.90
wrapMethod · 0.80

Tested by

no test coverage detected