com.espertech.esper.epl.view
Class OutputProcessViewConditionSnapshot

java.lang.Object
  com.espertech.esper.epl.view.OutputProcessViewBase
      com.espertech.esper.epl.view.OutputProcessViewBaseWAfter
          com.espertech.esper.epl.view.OutputProcessViewConditionSnapshot

All Implemented Interfaces:

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

Direct Known Subclasses:

OutputProcessViewConditionSnapshotPostProcess

public class OutputProcessViewConditionSnapshot
extends OutputProcessViewBaseWAfter

A view that handles the "output snapshot" keyword in output rate stabilizing.

Field Summary

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

childView, joinExecutionStrategy, parentView, resultSetProcessor

Constructor Summary

OutputProcessViewConditionSnapshot(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory, ResultSetProcessor resultSetProcessor, java.lang.Long afterConditionTime, java.lang.Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, OutputProcessViewConditionFactory parent, AgentInstanceContext agentInstanceContext)

Method Summary

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()
java.util.Iterator<EventBean>	iterator() Allows iteration through all elements in this event collection.
void	output(boolean forceUpdate, UniformPair<EventBean[]> results)
void	process(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, ExprEvaluatorContext exprEvaluatorContext) This process (update) method is for participation in a join.
void	stop() Stops the underlying resources.
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.epl.view.OutputProcessViewBaseWAfter

checkAfterCondition, checkAfterCondition, checkAfterCondition

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

addView, getEventType, 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

Constructor Detail

OutputProcessViewConditionSnapshot

public OutputProcessViewConditionSnapshot(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
                                          ResultSetProcessor resultSetProcessor,
                                          java.lang.Long afterConditionTime,
                                          java.lang.Integer afterConditionNumberOfEvents,
                                          boolean afterConditionSatisfied,
                                          OutputProcessViewConditionFactory parent,
                                          AgentInstanceContext agentInstanceContext)

Method Detail

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

Overrides:

stop in class OutputProcessViewBaseWAfter

getNumChangesetRows

public int getNumChangesetRows()

Specified by:

getNumChangesetRows in class OutputProcessViewBase

getOptionalOutputCondition

public OutputCondition getOptionalOutputCondition()

Specified by:

getOptionalOutputCondition in class OutputProcessViewBase

getOptionalDeltaSet

public OutputProcessViewConditionDeltaSet getOptionalDeltaSet()

Specified by:

getOptionalDeltaSet in class OutputProcessViewBase

getOptionalAfterConditionState

public OutputProcessViewAfterState getOptionalAfterConditionState()

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.

Parameters:

newData - - new events

oldData - - old events

process

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

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

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

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

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 java.util.Iterator<EventBean> iterator()

Description copied from interface: EventCollection

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

Returns:

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

terminated

public void terminated()