public class AggregationStateMinMaxByEverWFilter extends AggregationStateMinMaxByEver
currentMinMax, currentMinMaxBean, spec
Constructor and Description |
---|
AggregationStateMinMaxByEverWFilter(AggregationStateMinMaxByEverSpec spec) |
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Enter an event.
|
addEvent, applyEnterCodegen, applyLeave, clear, clearCodegen, collectionReadOnly, getCurrentMinMax, getCurrentMinMaxBean, getFirstValue, getFirstValueCodegen, getLastValue, getLastValueCodegen, getReverseIterator, getSpec, iterator, rowMemberCodegen, setCurrentMinMax, setCurrentMinMaxBean, size
public AggregationStateMinMaxByEverWFilter(AggregationStateMinMaxByEverSpec spec)
public void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
AggregationState
applyEnter
in interface AggregationState
applyEnter
in class AggregationStateMinMaxByEver
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to addexprEvaluatorContext
- expression eval context