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

Class ReducerDetector

python/pathway/internals/sql/processing.py:24–34  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

22
23
24class ReducerDetector(IdentityTransform):
25 contains_reducers: bool
26
27 def __init__(self):
28 self.contains_reducers = False
29
30 def eval_reducer(
31 self, expression: expr.ReducerExpression, **kwargs
32 ) -> expr.ReducerExpression:
33 self.contains_reducers = True
34 return super().eval_reducer(expression, **kwargs)
35
36
37_expression_handlers: dict[type[sql_expr.Expression], Callable] = {}

Callers 1

_selectFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected