Package | Description |
---|---|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.handthru |
Result set processor for Un-Aggregated and Un-Grouped with having or output-rate-limiting or order-by
|
com.espertech.esper.epl.core.resultset.rowforall |
Result set processor for Fully-Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowperevent |
Result set processor for Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.epl.core.select |
Select-clause processing.
|
com.espertech.esper.epl.core.select.eval |
Select expression evaluators.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.property |
Classes for handling events-within-events.
|
com.espertech.esper.epl.table.merge |
Table on-merge handlers.
|
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
EPPreparedExecuteIUDSingleStreamExecInsert.getInsertHelper() |
Constructor and Description |
---|
EPPreparedExecuteIUDSingleStreamExecInsert(ExprEvaluatorContext exprEvaluatorContext,
SelectExprProcessor insertHelper,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor[] |
GroupByRollupPerLevelExpression.getSelectExprProcessor() |
Constructor and Description |
---|
GroupByRollupPerLevelExpression(SelectExprProcessor[] selectExprProcessor,
ExprEvaluator[] optionalHavingNodes) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
ResultSetProcessorAggregateGroupedImpl.getSelectExprProcessor()
Returns the select expression processor
|
SelectExprProcessor |
ResultSetProcessorAggregateGrouped.getSelectExprProcessor() |
Modifier and Type | Method and Description |
---|---|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsNoHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static void |
ResultSetProcessorUtil.populateSelectEventsHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
java.util.Collection<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
java.util.Collection<EventBean> result,
java.util.List<java.lang.Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
static EventBean[] |
ResultSetProcessorHandThroughUtil.getSelectEventsNoHavingHandThruJoin(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorHandThroughUtil.getSelectEventsNoHavingHandThruView(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
Applies the select-clause to the given events returning the selected events.
|
Constructor and Description |
---|
ResultSetProcessorSimpleFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
int numStreams) |
Constructor and Description |
---|
ResultSetProcessorRowForAllFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
ResultSetProcessorRowPerEventImpl.getSelectExprProcessor()
Returns the select expression processor
|
SelectExprProcessor |
ResultSetProcessorRowPerEvent.getSelectExprProcessor() |
Constructor and Description |
---|
ResultSetProcessorRowPerEventFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
Modifier and Type | Field and Description |
---|---|
protected SelectExprProcessor |
ResultSetProcessorRowPerGroupImpl.selectExprProcessor |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
ResultSetProcessorRowPerGroupImpl.getSelectExprProcessor()
Returns the select expression processor
|
SelectExprProcessor |
ResultSetProcessorRowPerGroup.getSelectExprProcessor() |
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessor |
SelectExprProcessorCompiler.allocateSelectExprEvaluator(EventAdapterService eventAdapterService,
SelectExprProcessorForge forge,
EngineImportService engineImportService,
java.lang.Class compiledByClass,
boolean onDemandQuery,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprWildcardTableProcessor.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprWildcardProcessor.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprResultProcessor.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprProcessorWDeliveryCallback.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprProcessorForge.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprJoinWildcardProcessorTableRows.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprJoinWildcardProcessorObjectArray.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprJoinWildcardProcessorMap.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceBase.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeBase.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeNoEval.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessor |
EvalSelectStreamBase.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalSelectNoWildcardObjectArray.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalSelectNoWildcardMap.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalSelectNoWildcardEmptyProps.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertWildcardRevision.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertWildcardJoinRevision.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertWildcardBean.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertNoWildcardObjectArrayRemapWWiden.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertNoWildcardObjectArrayRemap.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertNoWildcardObjectArray.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertCoercionObjectArray.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertCoercionMap.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertCoercionAvro.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertBeanWrapRecast.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalInsertBeanRecast.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalBaseMap.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
SelectExprProcessor |
EvalBaseFirstProp.getSelectExprProcessor(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Constructor and Description |
---|
NamedWindowOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
java.lang.String insertIntoTableName,
TableService tableService,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit) |
Constructor and Description |
---|
PropertyEvaluatorSelect(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
PropertyEvaluatorAccumulative accumulative) |
Constructor and Description |
---|
TableOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit,
TableStateRowFactory tableStateRowFactory) |