Class OutputProcessViewAfterStateImpl
java.lang.Object
com.espertech.esper.common.internal.epl.output.view.OutputProcessViewAfterStateImpl
- All Implemented Interfaces:
OutputProcessViewAfterState
-
Field Summary
-
Constructor Summary
ConstructorDescriptionOutputProcessViewAfterStateImpl
(Long afterConditionTime, Integer afterConditionNumberOfEvents) -
Method Summary
Modifier and TypeMethodDescriptionboolean
checkUpdateAfterCondition
(EventBean[] newEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.boolean
checkUpdateAfterCondition
(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.boolean
checkUpdateAfterCondition
(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.void
destroy()
-
Field Details
-
isAfterConditionSatisfied
protected boolean isAfterConditionSatisfied
-
-
Constructor Details
-
OutputProcessViewAfterStateImpl
-
-
Method Details
-
checkUpdateAfterCondition
Returns true if the after-condition is satisfied.- Specified by:
checkUpdateAfterCondition
in interfaceOutputProcessViewAfterState
- Parameters:
newEvents
- is the view new events- Returns:
- indicator for output condition
-
checkUpdateAfterCondition
public boolean checkUpdateAfterCondition(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.- Specified by:
checkUpdateAfterCondition
in interfaceOutputProcessViewAfterState
- Parameters:
newEvents
- is the join new events- Returns:
- indicator for output condition
-
checkUpdateAfterCondition
public boolean checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.- Specified by:
checkUpdateAfterCondition
in interfaceOutputProcessViewAfterState
- Parameters:
newOldEvents
- is the new and old events pair- Returns:
- indicator for output condition
-
destroy
public void destroy()- Specified by:
destroy
in interfaceOutputProcessViewAfterState
-