public class AggregationStateLinearWFilter extends AggregationStateLinearImpl
events, streamId
Constructor and Description |
---|
AggregationStateLinearWFilter(int streamId,
ExprEvaluator filter) |
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Enter an event.
|
void |
applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Remove an event.
|
void |
clear()
Clear all events in the group.
|
applyEnterCodegen, applyLeaveCodegen, clearCodegen, codegenGetFirstValue, codegenGetLastValue, codegenIterator, codegenSize, collectionReadOnly, collectionReadOnlyCodegen, getEvents, getFirstNthValue, getFirstNthValueCodegen, getFirstValue, getLastNthValue, getLastNthValueCodegen, getLastValue, iterator, rowMemberCodegen, size
public AggregationStateLinearWFilter(int streamId, ExprEvaluator filter)
public void clear()
AggregationState
clear
in interface AggregationState
clear
in class AggregationStateLinearImpl
public void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
AggregationState
applyLeave
in interface AggregationState
applyLeave
in class AggregationStateLinearImpl
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to removeexprEvaluatorContext
- expression eval contextpublic void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
AggregationState
applyEnter
in interface AggregationState
applyEnter
in class AggregationStateLinearImpl
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to addexprEvaluatorContext
- expression eval context