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

Class OutputProcessViewConditionDefault

java.lang.Object

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

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

OutputProcessViewConditionDefaultPostProcess

public class OutputProcessViewConditionDefault
extends OutputProcessViewBaseWAfter
implements OutputProcessViewWithDeltaSet

A view that prepares output events, batching incoming events and invoking the result set processor as necessary.

Handles output rate limiting or stabilizing.

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.output.view.OutputProcessViewBaseWAfter

agentInstanceContext, 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

Constructor and Description
OutputProcessViewConditionDefault(ResultSetProcessor resultSetProcessor, Long afterConditionTime, Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, OutputProcessViewConditionFactory parent, AgentInstanceContext agentInstanceContext, boolean isJoin, EventType[] eventTypes)

Method Summary

Modifier and Type	Method and Description
protected void	continueOutputProcessingJoin(boolean doOutput, boolean forceUpdate) Called once the output condition has been met.
protected void	continueOutputProcessingView(boolean doOutput, boolean forceUpdate) Called once the output condition has been met.
int	getNumChangesetRows()
OutputProcessViewAfterState	getOptionalAfterConditionState()
OutputProcessViewConditionDeltaSet	getOptionalDeltaSet()
OutputCondition	getOptionalOutputCondition()
Iterator<EventBean>	iterator() Allows iteration through all elements in this viewable.
protected void	output(boolean forceUpdate, UniformPair<EventBean[]> results)
void	process(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents, ExprEvaluatorContext exprEvaluatorContext) This process (update) method is for participation in a join.
void	stop(AgentInstanceStopServices services)
void	terminated()
void	update(EventBean[] newData, EventBean[] oldData) The update method is called if the view does not participate in a join.

Methods inherited from class com.espertech.esper.common.internal.epl.output.view.OutputProcessViewBaseWAfter

checkAfterCondition, checkAfterCondition, checkAfterCondition, getEventType

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

getChild, 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 java.lang.Iterable

forEach, spliterator

Constructor Detail

OutputProcessViewConditionDefault

public OutputProcessViewConditionDefault(ResultSetProcessor resultSetProcessor,
                                         Long afterConditionTime,
                                         Integer afterConditionNumberOfEvents,
                                         boolean afterConditionSatisfied,
                                         OutputProcessViewConditionFactory parent,
                                         AgentInstanceContext agentInstanceContext,
                                         boolean isJoin,
                                         EventType[] eventTypes)

Method Detail

getNumChangesetRows

public int getNumChangesetRows()

Specified by:

getNumChangesetRows in class OutputProcessView

getOptionalDeltaSet

public OutputProcessViewConditionDeltaSet getOptionalDeltaSet()

Specified by:

getOptionalDeltaSet in interface OutputProcessViewWithDeltaSet

getOptionalOutputCondition

public OutputCondition getOptionalOutputCondition()

Specified by:

getOptionalOutputCondition in class OutputProcessView

getOptionalAfterConditionState

public OutputProcessViewAfterState getOptionalAfterConditionState()

Specified by:

getOptionalAfterConditionState in interface OutputProcessViewWithAfter

Overrides:

getOptionalAfterConditionState in class OutputProcessViewBaseWAfter

update

public void update(EventBean[] newData,
                   EventBean[] oldData)

The update method is called if the view does not participate in a join.

Specified by:

update in interface View

Parameters:

newData - - new events

oldData - - old events

process

public void process(Set<MultiKey<EventBean>> newEvents,
                    Set<MultiKey<EventBean>> oldEvents,
                    ExprEvaluatorContext exprEvaluatorContext)

This process (update) method is for participation in a join.

Specified by:

process in interface JoinSetProcessor

Parameters:

newEvents - - new events

oldEvents - - old events

exprEvaluatorContext - expression evaluation context

continueOutputProcessingView

protected void continueOutputProcessingView(boolean doOutput,
                                            boolean forceUpdate)

Called once the output condition has been met. Invokes the result set processor. Used for non-join event data.

Parameters:

doOutput - - true if the batched events should actually be output as well as processed, false if they should just be processed

forceUpdate - - true if output should be made even when no updating events have arrived

output

protected void output(boolean forceUpdate,
                      UniformPair<EventBean[]> results)

stop

public void stop(AgentInstanceStopServices services)

Specified by:

stop in interface AgentInstanceStopCallback

Overrides:

stop in class OutputProcessViewBaseWAfter

continueOutputProcessingJoin

protected void continueOutputProcessingJoin(boolean doOutput,
                                            boolean forceUpdate)

Called once the output condition has been met. Invokes the result set processor. Used for join event data.

Parameters:

doOutput - - true if the batched events should actually be output as well as processed, false if they should just be processed

forceUpdate - - true if output should be made even when no updating events have arrived

iterator

public Iterator<EventBean> iterator()

Description copied from interface: Viewable

Allows iteration through all elements in this viewable. The iterator will return the elements in the collection in their natural order, or, if there is no natural ordering, in some unpredictable order.

Specified by:

iterator in interface Viewable

Specified by:

iterator in interface Iterable<EventBean>

Returns:

an iterator which will go through all current elements in the collection.

terminated

public void terminated()

Specified by:

terminated in interface OutputProcessViewTerminable