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:

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

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

INSTANCE_NO_ACTION

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 java.lang.Iterable

forEach, spliterator

Constructor Detail

OutputProcessViewConditionDefaultPostProcess

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

Method Detail

output

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

Overrides:

output in class OutputProcessViewConditionDefault