com.espertech.esper.epl.core
Class ResultSetProcessorHelperFactoryImpl

java.lang.Object
  com.espertech.esper.epl.core.ResultSetProcessorHelperFactoryImpl

All Implemented Interfaces:

ResultSetProcessorHelperFactory

public class ResultSetProcessorHelperFactoryImpl
extends java.lang.Object
implements ResultSetProcessorHelperFactory

Constructor Summary

ResultSetProcessorHelperFactoryImpl()

Method Summary

OutputProcessViewAfterState	makeOutputConditionAfter(java.lang.Long afterConditionTime, java.lang.Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, AgentInstanceContext agentInstanceContext)
OutputProcessViewConditionDeltaSet	makeOutputConditionChangeSet(boolean isJoin, AgentInstanceContext agentInstanceContext)
OutputConditionFactory	makeOutputConditionCount(int rate, VariableMetaData variableMetaData, StatementContext statementContext)
OutputConditionFactory	makeOutputConditionCrontab(java.util.List<ExprNode> crontabAtSchedule, StatementContext statementContext, boolean isStartConditionOnCreation)
OutputConditionFactory	makeOutputConditionExpression(ExprNode whenExpressionNode, java.util.List<OnTriggerSetAssignment> thenExpressions, StatementContext statementContext, ExprNode andAfterTerminateExpr, java.util.List<OnTriggerSetAssignment> andAfterTerminateThenExpressions, boolean isStartConditionOnCreation)
OutputConditionFactory	makeOutputConditionTime(ExprTimePeriod timePeriodExpr, boolean isStartConditionOnCreation)
ResultSetProcessorAggregateAllOutputAllHelper	makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor, AgentInstanceContext agentInstanceContext)
ResultSetProcessorAggregateAllOutputLastHelperImpl	makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor, AgentInstanceContext agentInstanceContext)
ResultSetProcessorAggregateGroupedOutputAllHelper	makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext, ResultSetProcessorAggregateGrouped processor, ResultSetProcessorAggregateGroupedFactory prototype)
ResultSetProcessorAggregateGroupedOutputLastHelper	makeRSAggregateGroupedOutputLastOpt(AgentInstanceContext agentInstanceContext, ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped, ResultSetProcessorAggregateGroupedFactory prototype)
ResultSetProcessorGroupedOutputAllGroupReps	makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext, ExprEvaluator[] groupKeyExpressions, int numStreams)
ResultSetProcessorGroupedOutputFirstHelper	makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext, ExprEvaluator[] groupKeyNodes, OutputConditionPolledFactory optionalOutputFirstConditionFactory, AggregationGroupByRollupDesc optionalGroupByRollupDesc, int optionalRollupLevel)
ResultSetProcessorRowForAllOutputAllHelper	makeRSRowForAllOutputAll(ResultSetProcessorRowForAll processor, ResultSetProcessorRowForAllFactory prototype, AgentInstanceContext agentInstanceContext)
ResultSetProcessorRowForAllOutputLastHelper	makeRSRowForAllOutputLast(ResultSetProcessorRowForAll processor, ResultSetProcessorRowForAllFactory prototype, AgentInstanceContext agentInstanceContext)
ResultSetProcessorRowPerGroupOutputAllHelper	makeRSRowPerGroupOutputAllOpt(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup, ResultSetProcessorRowPerGroupFactory prototype)
ResultSetProcessorRowPerGroupOutputLastHelper	makeRSRowPerGroupOutputLastOpt(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup, ResultSetProcessorRowPerGroupFactory prototype)
ResultSetProcessorRowPerGroupRollupOutputAllHelper	makeRSRowPerGroupRollupAll(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup, ResultSetProcessorRowPerGroupRollupFactory prototype)
ResultSetProcessorRowPerGroupRollupOutputLastHelper	makeRSRowPerGroupRollupLast(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup, ResultSetProcessorRowPerGroupRollupFactory prototype)
ResultSetProcessorRowPerGroupRollupUnboundHelper	makeRSRowPerGroupRollupSnapshotUnbound(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroupRollupFactory prototype)
ResultSetProcessorRowPerGroupUnboundGroupRep	makeRSRowPerGroupUnboundGroupRep(AgentInstanceContext agentInstanceContext, ResultSetProcessorRowPerGroupFactory prototype)
ResultSetProcessorSimpleOutputAllHelper	makeRSSimpleOutputAll(ResultSetProcessorSimpleFactory prototype, ResultSetProcessorSimple resultSetProcessorSimple, AgentInstanceContext agentInstanceContext)
ResultSetProcessorSimpleOutputLastHelper	makeRSSimpleOutputLast(ResultSetProcessorSimpleFactory prototype, ResultSetProcessorSimple simple, AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultSetProcessorHelperFactoryImpl

public ResultSetProcessorHelperFactoryImpl()

Method Detail

makeRSSimpleOutputLast

public ResultSetProcessorSimpleOutputLastHelper makeRSSimpleOutputLast(ResultSetProcessorSimpleFactory prototype,
                                                                       ResultSetProcessorSimple simple,
                                                                       AgentInstanceContext agentInstanceContext)

Specified by:

makeRSSimpleOutputLast in interface ResultSetProcessorHelperFactory

makeRSSimpleOutputAll

public ResultSetProcessorSimpleOutputAllHelper makeRSSimpleOutputAll(ResultSetProcessorSimpleFactory prototype,
                                                                     ResultSetProcessorSimple resultSetProcessorSimple,
                                                                     AgentInstanceContext agentInstanceContext)

Specified by:

makeRSSimpleOutputAll in interface ResultSetProcessorHelperFactory

makeOutputConditionChangeSet

public OutputProcessViewConditionDeltaSet makeOutputConditionChangeSet(boolean isJoin,
                                                                       AgentInstanceContext agentInstanceContext)

Specified by:

makeOutputConditionChangeSet in interface ResultSetProcessorHelperFactory

makeOutputConditionTime

public OutputConditionFactory makeOutputConditionTime(ExprTimePeriod timePeriodExpr,
                                                      boolean isStartConditionOnCreation)

Specified by:

makeOutputConditionTime in interface ResultSetProcessorHelperFactory

makeOutputConditionExpression

public OutputConditionFactory makeOutputConditionExpression(ExprNode whenExpressionNode,
                                                            java.util.List<OnTriggerSetAssignment> thenExpressions,
                                                            StatementContext statementContext,
                                                            ExprNode andAfterTerminateExpr,
                                                            java.util.List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
                                                            boolean isStartConditionOnCreation)
                                                     throws ExprValidationException

Specified by:

makeOutputConditionExpression in interface ResultSetProcessorHelperFactory

Throws:

ExprValidationException

makeOutputConditionCrontab

public OutputConditionFactory makeOutputConditionCrontab(java.util.List<ExprNode> crontabAtSchedule,
                                                         StatementContext statementContext,
                                                         boolean isStartConditionOnCreation)
                                                  throws ExprValidationException

Specified by:

makeOutputConditionCrontab in interface ResultSetProcessorHelperFactory

Throws:

ExprValidationException

makeOutputConditionCount

public OutputConditionFactory makeOutputConditionCount(int rate,
                                                       VariableMetaData variableMetaData,
                                                       StatementContext statementContext)

Specified by:

makeOutputConditionCount in interface ResultSetProcessorHelperFactory

makeOutputConditionAfter

public OutputProcessViewAfterState makeOutputConditionAfter(java.lang.Long afterConditionTime,
                                                            java.lang.Integer afterConditionNumberOfEvents,
                                                            boolean afterConditionSatisfied,
                                                            AgentInstanceContext agentInstanceContext)

Specified by:

makeOutputConditionAfter in interface ResultSetProcessorHelperFactory

makeRSAggregateAllOutputLast

public ResultSetProcessorAggregateAllOutputLastHelperImpl makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor,
                                                                                       AgentInstanceContext agentInstanceContext)

Specified by:

makeRSAggregateAllOutputLast in interface ResultSetProcessorHelperFactory

makeRSAggregateAllOutputAll

public ResultSetProcessorAggregateAllOutputAllHelper makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor,
                                                                                 AgentInstanceContext agentInstanceContext)

Specified by:

makeRSAggregateAllOutputAll in interface ResultSetProcessorHelperFactory

makeRSRowForAllOutputLast

public ResultSetProcessorRowForAllOutputLastHelper makeRSRowForAllOutputLast(ResultSetProcessorRowForAll processor,
                                                                             ResultSetProcessorRowForAllFactory prototype,
                                                                             AgentInstanceContext agentInstanceContext)

Specified by:

makeRSRowForAllOutputLast in interface ResultSetProcessorHelperFactory

makeRSRowForAllOutputAll

public ResultSetProcessorRowForAllOutputAllHelper makeRSRowForAllOutputAll(ResultSetProcessorRowForAll processor,
                                                                           ResultSetProcessorRowForAllFactory prototype,
                                                                           AgentInstanceContext agentInstanceContext)

Specified by:

makeRSRowForAllOutputAll in interface ResultSetProcessorHelperFactory

makeRSGroupedOutputAllNoOpt

public ResultSetProcessorGroupedOutputAllGroupReps makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
                                                                               ExprEvaluator[] groupKeyExpressions,
                                                                               int numStreams)

Specified by:

makeRSGroupedOutputAllNoOpt in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupOutputAllOpt

public ResultSetProcessorRowPerGroupOutputAllHelper makeRSRowPerGroupOutputAllOpt(AgentInstanceContext agentInstanceContext,
                                                                                  ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
                                                                                  ResultSetProcessorRowPerGroupFactory prototype)

Specified by:

makeRSRowPerGroupOutputAllOpt in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupOutputLastOpt

public ResultSetProcessorRowPerGroupOutputLastHelper makeRSRowPerGroupOutputLastOpt(AgentInstanceContext agentInstanceContext,
                                                                                    ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
                                                                                    ResultSetProcessorRowPerGroupFactory prototype)

Specified by:

makeRSRowPerGroupOutputLastOpt in interface ResultSetProcessorHelperFactory

makeRSGroupedOutputFirst

public ResultSetProcessorGroupedOutputFirstHelper makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
                                                                           ExprEvaluator[] groupKeyNodes,
                                                                           OutputConditionPolledFactory optionalOutputFirstConditionFactory,
                                                                           AggregationGroupByRollupDesc optionalGroupByRollupDesc,
                                                                           int optionalRollupLevel)

Specified by:

makeRSGroupedOutputFirst in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupUnboundGroupRep

public ResultSetProcessorRowPerGroupUnboundGroupRep makeRSRowPerGroupUnboundGroupRep(AgentInstanceContext agentInstanceContext,
                                                                                     ResultSetProcessorRowPerGroupFactory prototype)

Specified by:

makeRSRowPerGroupUnboundGroupRep in interface ResultSetProcessorHelperFactory

makeRSAggregateGroupedOutputAll

public ResultSetProcessorAggregateGroupedOutputAllHelper makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext,
                                                                                         ResultSetProcessorAggregateGrouped processor,
                                                                                         ResultSetProcessorAggregateGroupedFactory prototype)

Specified by:

makeRSAggregateGroupedOutputAll in interface ResultSetProcessorHelperFactory

makeRSAggregateGroupedOutputLastOpt

public ResultSetProcessorAggregateGroupedOutputLastHelper makeRSAggregateGroupedOutputLastOpt(AgentInstanceContext agentInstanceContext,
                                                                                              ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped,
                                                                                              ResultSetProcessorAggregateGroupedFactory prototype)

Specified by:

makeRSAggregateGroupedOutputLastOpt in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupRollupLast

public ResultSetProcessorRowPerGroupRollupOutputLastHelper makeRSRowPerGroupRollupLast(AgentInstanceContext agentInstanceContext,
                                                                                       ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
                                                                                       ResultSetProcessorRowPerGroupRollupFactory prototype)

Specified by:

makeRSRowPerGroupRollupLast in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupRollupAll

public ResultSetProcessorRowPerGroupRollupOutputAllHelper makeRSRowPerGroupRollupAll(AgentInstanceContext agentInstanceContext,
                                                                                     ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
                                                                                     ResultSetProcessorRowPerGroupRollupFactory prototype)

Specified by:

makeRSRowPerGroupRollupAll in interface ResultSetProcessorHelperFactory

makeRSRowPerGroupRollupSnapshotUnbound

public ResultSetProcessorRowPerGroupRollupUnboundHelper makeRSRowPerGroupRollupSnapshotUnbound(AgentInstanceContext agentInstanceContext,
                                                                                               ResultSetProcessorRowPerGroupRollupFactory prototype)

Specified by:

makeRSRowPerGroupRollupSnapshotUnbound in interface ResultSetProcessorHelperFactory