com.espertech.esper.epl.core

Interface ResultSetProcessorHelperFactory

All Known Implementing Classes:

ResultSetProcessorHelperFactoryImpl

public interface ResultSetProcessorHelperFactory

Method Summary

Modifier and Type	Method and Description
OutputProcessViewAfterState	makeOutputConditionAfter(Long afterConditionTime, Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, AgentInstanceContext agentInstanceContext)
OutputProcessViewConditionDeltaSet	makeOutputConditionChangeSet(boolean isJoin, AgentInstanceContext agentInstanceContext)
OutputConditionFactory	makeOutputConditionCount(int rate, VariableMetaData variableMetaData, StatementContext statementContext)
OutputConditionFactory	makeOutputConditionCrontab(List<ExprNode> crontabAtSchedule, StatementContext statementContext, boolean isStartConditionOnCreation)
OutputConditionFactory	makeOutputConditionExpression(ExprNode whenExpressionNode, List<OnTriggerSetAssignment> thenExpressions, StatementContext statementContext, ExprNode andAfterTerminateExpr, List<OnTriggerSetAssignment> andAfterTerminateThenExpressions, boolean isStartConditionOnCreation)
OutputConditionFactory	makeOutputConditionTime(ExprTimePeriod timePeriodExpr, boolean isStartConditionOnCreation)
ResultSetProcessorAggregateAllOutputAllHelper	makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor, AgentInstanceContext agentInstanceContext)
ResultSetProcessorAggregateAllOutputLastHelper	makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor, AgentInstanceContext agentInstanceContext)
ResultSetProcessorAggregateGroupedOutputAllHelper	makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext, ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped, ResultSetProcessorAggregateGroupedFactory prototype)
ResultSetProcessorAggregateGroupedOutputLastHelper	makeRSAggregateGroupedOutputLastOpt(AgentInstanceContext agentInstanceContext, ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped, ResultSetProcessorAggregateGroupedFactory prototype)
ResultSetProcessorGroupedOutputAllGroupReps	makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext, ExprNode[] groupKeyExpressions, int numStreams)
ResultSetProcessorGroupedOutputFirstHelper	makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext, ExprEvaluator[] groupKeyNodes, ExprNode[] groupKeyNodeExpressions, 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)

Method Detail

makeOutputConditionChangeSet

OutputProcessViewConditionDeltaSet makeOutputConditionChangeSet(boolean isJoin,
                                                                AgentInstanceContext agentInstanceContext)

makeOutputConditionTime

OutputConditionFactory makeOutputConditionTime(ExprTimePeriod timePeriodExpr,
                                               boolean isStartConditionOnCreation)

makeOutputConditionExpression

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

Throws:

ExprValidationException

makeOutputConditionCrontab

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

Throws:

ExprValidationException

makeOutputConditionCount

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

makeOutputConditionAfter

OutputProcessViewAfterState makeOutputConditionAfter(Long afterConditionTime,
                                                     Integer afterConditionNumberOfEvents,
                                                     boolean afterConditionSatisfied,
                                                     AgentInstanceContext agentInstanceContext)

makeRSSimpleOutputLast

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

makeRSSimpleOutputAll

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

makeRSAggregateAllOutputLast

ResultSetProcessorAggregateAllOutputLastHelper makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor,
                                                                            AgentInstanceContext agentInstanceContext)

makeRSAggregateAllOutputAll

ResultSetProcessorAggregateAllOutputAllHelper makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor,
                                                                          AgentInstanceContext agentInstanceContext)

makeRSRowForAllOutputLast

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

makeRSRowForAllOutputAll

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

makeRSGroupedOutputAllNoOpt

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

makeRSRowPerGroupOutputAllOpt

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

makeRSRowPerGroupOutputLastOpt

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

makeRSRowPerGroupUnboundGroupRep

ResultSetProcessorRowPerGroupUnboundGroupRep makeRSRowPerGroupUnboundGroupRep(AgentInstanceContext agentInstanceContext,
                                                                              ResultSetProcessorRowPerGroupFactory prototype)

makeRSAggregateGroupedOutputAll

ResultSetProcessorAggregateGroupedOutputAllHelper makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext,
                                                                                  ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped,
                                                                                  ResultSetProcessorAggregateGroupedFactory prototype)

makeRSAggregateGroupedOutputLastOpt

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

makeRSGroupedOutputFirst

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

makeRSRowPerGroupRollupLast

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

makeRSRowPerGroupRollupAll

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

makeRSRowPerGroupRollupSnapshotUnbound

ResultSetProcessorRowPerGroupRollupUnboundHelper makeRSRowPerGroupRollupSnapshotUnbound(AgentInstanceContext agentInstanceContext,
                                                                                        ResultSetProcessorRowPerGroupRollupFactory prototype)