com.espertech.esper.epl.view

Class OutputProcessViewBaseWAfter

java.lang.Object

com.espertech.esper.epl.view.OutputProcessViewBase

com.espertech.esper.epl.view.OutputProcessViewBaseWAfter

All Implemented Interfaces:

JoinSetIndicator, JoinSetProcessor, OutputProcessViewTerminable, StopCallback, EventCollection, View, Viewable, Iterable<EventBean>

Direct Known Subclasses:

OutputProcessViewConditionDefault, OutputProcessViewConditionFirst, OutputProcessViewConditionLastAllUnord, OutputProcessViewConditionSnapshot, OutputProcessViewDirectDistinctOrAfter

public abstract class OutputProcessViewBaseWAfter
extends OutputProcessViewBase

Field Summary

Fields inherited from class com.espertech.esper.epl.view.OutputProcessViewBase

childView, joinExecutionStrategy, parentView, resultSetProcessor

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OutputProcessViewBaseWAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory, AgentInstanceContext agentInstanceContext, ResultSetProcessor resultSetProcessor, Long afterConditionTime, Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied)

Method Summary

Modifier and Type	Method and Description
boolean	checkAfterCondition(EventBean[] newEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
boolean	checkAfterCondition(Set<MultiKey<EventBean>> newEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
boolean	checkAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
OutputProcessViewAfterState	getOptionalAfterConditionState()
void	stop() Stops the underlying resources.

Methods inherited from class com.espertech.esper.epl.view.OutputProcessViewBase

addView, getEventType, getNumChangesetRows, getOptionalDeltaSet, getOptionalOutputCondition, getParent, getResultSetProcessor, getViews, hasViews, removeAllViews, removeView, setJoinExecutionStrategy, setParent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.espertech.esper.view.View

update

Methods inherited from interface com.espertech.esper.view.EventCollection

iterator

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.espertech.esper.epl.join.base.JoinSetProcessor

process

Methods inherited from interface com.espertech.esper.epl.view.OutputProcessViewTerminable

terminated

Constructor Detail

OutputProcessViewBaseWAfter

protected OutputProcessViewBaseWAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
                                      AgentInstanceContext agentInstanceContext,
                                      ResultSetProcessor resultSetProcessor,
                                      Long afterConditionTime,
                                      Integer afterConditionNumberOfEvents,
                                      boolean afterConditionSatisfied)

Method Detail

getOptionalAfterConditionState

public OutputProcessViewAfterState getOptionalAfterConditionState()

Specified by:

getOptionalAfterConditionState in class OutputProcessViewBase

checkAfterCondition

public boolean checkAfterCondition(EventBean[] newEvents,
                                   StatementContext statementContext)

Returns true if the after-condition is satisfied.

Parameters:

newEvents - is the view new events

statementContext - context

Returns:

indicator for output condition

checkAfterCondition

public boolean checkAfterCondition(Set<MultiKey<EventBean>> newEvents,
                                   StatementContext statementContext)

Returns true if the after-condition is satisfied.

Parameters:

newEvents - is the join new events

statementContext - context

Returns:

indicator for output condition

checkAfterCondition

public boolean checkAfterCondition(UniformPair<EventBean[]> newOldEvents,
                                   StatementContext statementContext)

Returns true if the after-condition is satisfied.

Parameters:

newOldEvents - is the new and old events pair

statementContext - context

Returns:

indicator for output condition

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.