Package | Description |
---|---|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
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.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessor |
EPStatementStartMethodHelperAssignExpr.getAssignResultSetProcessor(AgentInstanceContext agentInstanceContext,
ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
boolean isSubquery,
Integer subqueryNumber,
boolean isFireAndForget) |
Modifier and Type | Method and Description |
---|---|
static Pair<ResultSetProcessor,AggregationService> |
EPStatementStartMethodHelperUtil.startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
AgentInstanceContext agentInstanceContext,
boolean isSubquery,
Integer subqueryNumber) |
Modifier and Type | Class and Description |
---|---|
class |
ResultSetProcessorAggregateAll
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and not all of the properties in the select clause are under an aggregation function.
|
class |
ResultSetProcessorAggregateGrouped
Result-set processor for the aggregate-grouped case:
there is a group-by and one or more non-aggregation event properties in the select clause are not listed in the group by,
and there are aggregation functions.
|
class |
ResultSetProcessorBaseSimple
Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
|
class |
ResultSetProcessorHandThrough
Result set processor for the hand-through case:
no aggregation functions used in the select clause, and no group-by, no having and ordering.
|
class |
ResultSetProcessorRowForAll
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and all properties in the select clause are under an aggregation function.
|
class |
ResultSetProcessorRowPerGroup
Result set processor for the fully-grouped case:
there is a group-by and all non-aggregation event properties in the select clause are listed in the group by,
and there are aggregation functions.
|
class |
ResultSetProcessorRowPerGroupRollup |
class |
ResultSetProcessorRowPerGroupRollupUnbound |
class |
ResultSetProcessorRowPerGroupUnbound |
class |
ResultSetProcessorSimple
Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
|
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
ResultSetProcessorSimpleFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorRowPerGroupRollupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorRowPerGroupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorRowForAllFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorHandThroughFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorAggregateGroupedFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
ResultSetProcessor |
ResultSetProcessorAggregateAllFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
void |
JoinPreloadMethodNull.preloadAggregation(ResultSetProcessor resultSetProcessor) |
void |
JoinPreloadMethodImpl.preloadAggregation(ResultSetProcessor resultSetProcessor) |
void |
JoinPreloadMethod.preloadAggregation(ResultSetProcessor resultSetProcessor)
Initialize the result set process for the purpose of grouping and aggregation
from the join result set.
|
Modifier and Type | Method and Description |
---|---|
NamedWindowOnExprBaseView |
NamedWindowOnUpdateViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor) |
NamedWindowOnExprBaseView |
NamedWindowOnSelectViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor) |
NamedWindowOnExprBaseView |
NamedWindowOnMergeViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor) |
NamedWindowOnExprBaseView |
NamedWindowOnExprFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor) |
NamedWindowOnExprBaseView |
NamedWindowOnDeleteViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor) |
Constructor and Description |
---|
NamedWindowOnSelectView(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance rootView,
ExprEvaluatorContext exprEvaluatorContext,
NamedWindowOnSelectViewFactory parent,
ResultSetProcessor resultSetProcessor,
boolean audit,
boolean isDelete,
TableStateInstance tableStateInstanceInsertInto) |
Constructor and Description |
---|
TableOnSelectView(SubordWMatchExprLookupStrategy lookupStrategy,
TableStateInstance rootView,
ExprEvaluatorContext exprEvaluatorContext,
TableMetadata metadata,
TableOnSelectViewFactory parent,
ResultSetProcessor resultSetProcessor,
boolean audit,
boolean deleteAndSelect) |
Modifier and Type | Field and Description |
---|---|
protected ResultSetProcessor |
OutputProcessViewBase.resultSetProcessor |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessor |
OutputProcessViewBase.getResultSetProcessor() |
Modifier and Type | Method and Description |
---|---|
static Iterator<EventBean> |
OutputStrategyUtil.getIterator(JoinExecutionStrategy joinExecutionStrategy,
ResultSetProcessor resultSetProcessor,
Viewable parentView,
boolean distinct) |
OutputProcessViewBase |
OutputProcessViewFactoryCallback.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewBase |
OutputProcessViewFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewBase |
OutputProcessViewDirectFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewBase |
OutputProcessViewDirectDistinctOrAfterFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewBase |
OutputProcessViewConditionFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
OutputProcessViewBase(ResultSetProcessor resultSetProcessor) |
OutputProcessViewBaseCallback(ResultSetProcessor resultSetProcessor,
OutputProcessViewCallback callback) |
OutputProcessViewBaseWAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied) |
OutputProcessViewConditionDefault(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
boolean isJoin) |
OutputProcessViewConditionDefaultPostProcess(ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor,
boolean isJoin,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
OutputProcessViewConditionFirst(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewConditionFirstPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor) |
OutputProcessViewConditionLastAllUnord(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewConditionLastAllUnordPostProcessAll(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor) |
OutputProcessViewConditionSnapshot(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext) |
OutputProcessViewConditionSnapshotPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor) |
OutputProcessViewDirect(ResultSetProcessor resultSetProcessor,
OutputProcessViewDirectFactory parent) |
OutputProcessViewDirectDistinctOrAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewDirectDistinctOrAfterFactory parent) |
OutputProcessViewDirectDistinctOrAfterPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
Long afterConditionTime,
Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewDirectDistinctOrAfterFactory parent,
OutputStrategyPostProcess postProcessor) |
OutputProcessViewDirectPostProcess(ResultSetProcessor resultSetProcessor,
OutputProcessViewDirectFactory parent,
OutputStrategyPostProcess postProcessor) |
Modifier and Type | Field and Description |
---|---|
protected ResultSetProcessor[] |
RouteResultViewHandlerBase.processors |