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

Class OutputProcessViewConditionFirstPostProcess

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.OutputProcessViewConditionFirst

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

All Implemented Interfaces:

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

public class OutputProcessViewConditionFirstPostProcess
extends OutputProcessViewConditionFirst

Handles output rate limiting for FIRST, only applicable with a having-clause and no group-by clause.

Without having-clause the order of processing won't matter therefore its handled by the OutputProcessViewConditionDefault. With group-by the ResultSetProcessor handles the per-group first criteria.

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
OutputProcessViewConditionFirstPostProcess(ResultSetProcessor resultSetProcessor, Long afterConditionTime, Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, OutputProcessViewConditionFactory parent, AgentInstanceContext agentInstanceContext, OutputStrategyPostProcess postProcessor, StateMgmtSetting stateMgmtSetting)

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.OutputProcessViewConditionFirst

continueOutputProcessingJoin, continueOutputProcessingView, getNumChangesetRows, getOptionalAfterConditionState, 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

OutputProcessViewConditionFirstPostProcess

public OutputProcessViewConditionFirstPostProcess(ResultSetProcessor resultSetProcessor,
 Long afterConditionTime,
 Integer afterConditionNumberOfEvents,
 boolean afterConditionSatisfied,
 OutputProcessViewConditionFactory parent,
 AgentInstanceContext agentInstanceContext,
 OutputStrategyPostProcess postProcessor,
 StateMgmtSetting stateMgmtSetting)

Method Details

output

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

Overrides:

output in class OutputProcessViewConditionFirst