com.espertech.esper.common.internal.epl.output.view

Class OutputProcessViewBaseWAfter

java.lang.Object

com.espertech.esper.common.internal.epl.output.core.OutputProcessView

com.espertech.esper.common.internal.epl.output.view.OutputProcessViewBaseWAfter

All Implemented Interfaces:

AgentInstanceStopCallback, JoinSetIndicator, JoinSetProcessor, OutputProcessViewTerminable, OutputProcessViewWithAfter, View, Viewable, Iterable<EventBean>

Direct Known Subclasses:

OutputProcessViewConditionDefault, OutputProcessViewConditionFirst, OutputProcessViewConditionLastAllUnord, OutputProcessViewConditionSnapshot, OutputProcessViewDirectDistinctOrAfter

public abstract class OutputProcessViewBaseWAfter
extends OutputProcessView
implements OutputProcessViewWithAfter

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentInstanceContext	agentInstanceContext
protected ResultSetProcessor	resultSetProcessor

Fields inherited from class com.espertech.esper.common.internal.epl.output.core.OutputProcessView

child, joinExecutionStrategy, parentView

Fields inherited from interface com.espertech.esper.common.internal.context.util.AgentInstanceStopCallback

INSTANCE_NO_ACTION

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OutputProcessViewBaseWAfter(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.
EventType	getEventType() Provides metadata information about the type of object the event collection contains.
OutputProcessViewAfterState	getOptionalAfterConditionState()
void	stop(AgentInstanceStopServices services)

Methods inherited from class com.espertech.esper.common.internal.epl.output.core.OutputProcessView

getChild, getNumChangesetRows, getOptionalOutputCondition, getParent, setChild, 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.common.internal.view.core.View

update

Methods inherited from interface com.espertech.esper.common.internal.view.core.Viewable

iterator

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

process

Methods inherited from interface com.espertech.esper.common.internal.epl.output.core.OutputProcessViewTerminable

terminated

Field Detail

agentInstanceContext

protected final AgentInstanceContext agentInstanceContext

resultSetProcessor

protected final ResultSetProcessor resultSetProcessor

Constructor Detail

OutputProcessViewBaseWAfter

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

Method Detail

getOptionalAfterConditionState

public OutputProcessViewAfterState getOptionalAfterConditionState()

Specified by:

getOptionalAfterConditionState in interface OutputProcessViewWithAfter

getEventType

public EventType getEventType()

Description copied from interface: Viewable

Provides metadata information about the type of object the event collection contains.

Specified by:

getEventType in interface Viewable

Returns:

metadata for the objects in the collection

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(AgentInstanceStopServices services)

Specified by:

stop in interface AgentInstanceStopCallback