Package com.espertech.esper.common.internal.epl.output.condition

Class OutputProcessViewConditionDefaultPostProcess

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

com.espertech.esper.common.internal.epl.output.condition.OutputProcessViewConditionDefaultPostProcess

All Implemented Interfaces:

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

public class OutputProcessViewConditionDefaultPostProcess
extends OutputProcessViewConditionDefault

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, EPTYPE, joinExecutionStrategy, parentView

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

INSTANCE_NO_ACTION

Constructor Summary

Constructors

Constructor	Description
OutputProcessViewConditionDefaultPostProcess(ResultSetProcessor resultSetProcessor, Long afterConditionTime, Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, OutputProcessViewConditionFactory parent, AgentInstanceContext agentInstanceContext, OutputStrategyPostProcess postProcessor, EventType[] eventTypes, StateMgmtSetting stateMgmtSettings)

Method Summary

Modifier and Type	Method	Description
void	output(boolean forceUpdate, UniformPair<EventBean[]> results)

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

continueOutputProcessingJoin, continueOutputProcessingView, getNumChangesetRows, getOptionalAfterConditionState, getOptionalDeltaSet, getOptionalOutputCondition, iterator, process, stop, terminated, update

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 com.espertech.esper.common.internal.context.util.AgentInstanceMgmtCallback

transfer

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

OutputProcessViewConditionDefaultPostProcess

public OutputProcessViewConditionDefaultPostProcess(ResultSetProcessor resultSetProcessor,
 Long afterConditionTime,
 Integer afterConditionNumberOfEvents,
 boolean afterConditionSatisfied,
 OutputProcessViewConditionFactory parent,
 AgentInstanceContext agentInstanceContext,
 OutputStrategyPostProcess postProcessor,
 EventType[] eventTypes,
 StateMgmtSetting stateMgmtSettings)

Method Details

output

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

Overrides:

output in class OutputProcessViewConditionDefault