public class AggregationStateLinearJoinWFilter extends AggregationStateLinearJoinImpl
refSet, streamId
Constructor and Description |
---|
AggregationStateLinearJoinWFilter(int streamId,
ExprEvaluator filterEval) |
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Enter an event.
|
void |
applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Remove an event.
|
addEvent, clear, collectionReadOnly, getFirstNthValue, getFirstValue, getLastNthValue, getLastValue, getRefSet, iterator, removeEvent, size
public AggregationStateLinearJoinWFilter(int streamId, ExprEvaluator filterEval)
public void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
AggregationState
applyEnter
in interface AggregationState
applyEnter
in class AggregationStateLinearJoinImpl
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to addexprEvaluatorContext
- expression eval contextpublic void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
AggregationState
applyLeave
in interface AggregationState
applyLeave
in class AggregationStateLinearJoinImpl
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to removeexprEvaluatorContext
- expression eval context