com.espertech.esper.epl.core
Interface ResultSetProcessorHelperFactory
- All Known Implementing Classes:
- ResultSetProcessorHelperFactoryImpl
public interface ResultSetProcessorHelperFactory
|
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)
|
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,
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)
|
makeOutputConditionChangeSet
OutputProcessViewConditionDeltaSet makeOutputConditionChangeSet(boolean isJoin,
AgentInstanceContext agentInstanceContext)
makeOutputConditionTime
OutputConditionFactory makeOutputConditionTime(ExprTimePeriod timePeriodExpr,
boolean isStartConditionOnCreation)
makeOutputConditionExpression
OutputConditionFactory makeOutputConditionExpression(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
java.util.List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation)
throws ExprValidationException
- Throws:
ExprValidationException
makeOutputConditionCrontab
OutputConditionFactory makeOutputConditionCrontab(java.util.List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation)
throws ExprValidationException
- Throws:
ExprValidationException
makeOutputConditionCount
OutputConditionFactory makeOutputConditionCount(int rate,
VariableMetaData variableMetaData,
StatementContext statementContext)
makeOutputConditionAfter
OutputProcessViewAfterState makeOutputConditionAfter(java.lang.Long afterConditionTime,
java.lang.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,
ExprEvaluator[] 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,
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)