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

Method _filter

python/pathway/internals/table.py:578–585  ·  view source on GitHub ↗
(self, filter_expression: expr.ColumnExpression)

Source from the content-addressed store, hash-verified

576
577 @contextualized_operator
578 def _filter(self, filter_expression: expr.ColumnExpression) -> Table[TSchema]:
579 self._validate_expression(filter_expression)
580 filtering_column = self._eval(filter_expression)
581 assert self._universe == filtering_column.universe
582
583 context = clmn.FilterContext(filtering_column, self._id_column)
584
585 return self._table_with_context(context)
586
587 @trace_user_frame
588 @desugar

Callers 1

filterMethod · 0.95

Calls 3

_validate_expressionMethod · 0.95
_evalMethod · 0.95
_table_with_contextMethod · 0.95

Tested by

no test coverage detected