com.espertech.esper.epl.view
Class OutputProcessViewConditionFirstPostProcess

java.lang.Object
  com.espertech.esper.epl.view.OutputProcessViewBase
      com.espertech.esper.epl.view.OutputProcessViewBaseWAfter
          com.espertech.esper.epl.view.OutputProcessViewConditionFirst
              com.espertech.esper.epl.view.OutputProcessViewConditionFirstPostProcess

All Implemented Interfaces:

JoinSetIndicator, JoinSetProcessor, OutputProcessViewTerminable, StopCallback, EventCollection, View, Viewable, java.lang.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.epl.view.OutputProcessViewBase

childView, joinExecutionStrategy, parentView, resultSetProcessor

Constructor Summary

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

Method Summary

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

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

continueOutputProcessingJoin, continueOutputProcessingView, getNumChangesetRows, getOptionalOutputCondition, iterator, process, terminated, update

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

checkAfterCondition, checkAfterCondition, checkAfterCondition, stop

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

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

OutputProcessViewConditionFirstPostProcess

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

Method Detail

output

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