Package | Description |
---|---|
com.espertech.esper.epl.core |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Modifier and Type | Method and Description |
---|---|
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionCount(int rate,
VariableMetaData variableMetaData,
StatementContext statementContext) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionCount(int rate,
VariableMetaData variableMetaData,
StatementContext statementContext) |
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionCrontab(List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionCrontab(List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionExpression(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionExpression(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionTime(ExprTimePeriod timePeriodExpr,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionTime(ExprTimePeriod timePeriodExpr,
boolean isStartConditionOnCreation) |
Modifier and Type | Class and Description |
---|---|
class |
OutputConditionCountFactory |
class |
OutputConditionCrontabFactory
Output condition handling crontab-at schedule output.
|
class |
OutputConditionExpressionFactory
Output condition for output rate limiting that handles when-then expressions for controlling output.
|
class |
OutputConditionFirstFactory
An output condition that is satisfied at the first event
of either a time-based or count-based batch.
|
class |
OutputConditionNullFactory |
class |
OutputConditionTermFactory |
class |
OutputConditionTimeFactory
Output condition that is satisfied at the end
of every time interval of a given length.
|
Modifier and Type | Method and Description |
---|---|
static OutputConditionFactory |
OutputConditionFactoryFactory.createCondition(OutputLimitSpec outputLimitSpec,
StatementContext statementContext,
boolean isGrouped,
boolean isWithHavingClause,
boolean isStartConditionOnCreation,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
OutputConditionFactory |
OutputProcessViewConditionFactory.getOutputConditionFactory() |
Constructor and Description |
---|
OutputConditionFirst(OutputCallback outputCallback,
AgentInstanceContext agentInstanceContext,
OutputConditionFactory innerConditionFactory) |
OutputProcessViewConditionFactory(StatementContext statementContext,
OutputStrategyPostProcessFactory postProcessFactory,
boolean distinct,
ExprTimePeriod afterTimePeriod,
Integer afterConditionNumberOfEvents,
EventType resultEventType,
OutputConditionFactory outputConditionFactory,
int streamCount,
OutputProcessViewConditionFactory.ConditionType conditionType,
OutputLimitLimitType outputLimitLimitType,
boolean terminable,
boolean hasAfter,
boolean isUnaggregatedUngrouped,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |