Package | Description |
---|---|
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.codegen |
Result set processor code generation 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 | |
com.espertech.esper.epl.core.select.eval |
Select expression evaluators.
|
Modifier and Type | Method and Description |
---|---|
SelectExprProcessorForge[] |
GroupByRollupPerLevelForge.getSelectExprProcessorForges() |
Constructor and Description |
---|
GroupByRollupPerLevelForge(SelectExprProcessorForge[] selectExprProcessorForges,
ExprForge[] optionalHavingForges,
OrderByElementForge[][] optionalOrderByElements) |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams) |
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorFactoryDesc |
ResultSetProcessorFactoryCompiler.allocate(ResultSetProcessorFactoryForge forge,
ResultSetProcessorType resultSetProcessorType,
EventType resultEventType,
StatementContext stmtContext,
boolean isFireAndForget,
boolean join,
boolean hasOutputLimit,
ResultSetProcessorOutputConditionType outputConditionType,
boolean hasOutputLimitSnapshot,
SelectExprProcessorForge[] selectExprProcessorForge,
boolean rollup,
AggregationServiceForgeDesc aggregationServiceForgeDesc,
OrderByProcessorFactoryForge orderByProcessorForge) |
Constructor and Description |
---|
ResultSetProcessorHandThroughFactoryForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
boolean selectRStream) |
ResultSetProcessorSimpleForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean isSorting,
int numStreams) |
Constructor and Description |
---|
ResultSetProcessorRowForAllForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean hasOrderBy,
ResultSetProcessorOutputConditionType outputConditionType) |
Constructor and Description |
---|
ResultSetProcessorRowPerEventForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean hasOrderBy) |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessorForge |
SelectExprJoinWildcardProcessorFactory.create(Collection<Integer> assignedTypeNumberStack,
int statementId,
String statementName,
String[] streamNames,
EventType[] streamTypes,
EventAdapterService eventAdapterService,
InsertIntoDesc insertIntoDesc,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
Annotation[] annotations,
ConfigurationInformation configuration,
TableService tableService,
String engineURI,
boolean isFireAndForget) |
SelectExprProcessorForge |
SelectExprProcessorHelper.getForge() |
static SelectExprProcessorForge |
SelectExprInsertEventBeanFactory.getInsertUnderlyingJoinWildcard(EventAdapterService eventAdapterService,
EventType eventType,
String[] streamNames,
EventType[] streamTypes,
EngineImportService engineImportService,
String statementName,
String engineURI,
boolean isFireAndForget) |
static SelectExprProcessorForge |
SelectExprInsertEventBeanFactory.getInsertUnderlyingNonJoin(EventAdapterService eventAdapterService,
EventType eventType,
boolean isUsingWildcard,
StreamTypeService typeService,
ExprForge[] forges,
String[] columnNames,
Object[] expressionReturnTypes,
EngineImportService engineImportService,
InsertIntoDesc insertIntoDesc,
String[] columnNamesAsProvided,
boolean allowNestableTargetFragmentTypes,
String statementName) |
static SelectExprProcessorForge |
SelectExprProcessorFactory.getProcessor(Collection<Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoEventType,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
TableService tableService,
TimeProvider timeProvider,
String engineURI,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowMgmtService namedWindowMgmtService,
IntoTableSpec intoTableClause,
GroupByRollupInfo groupByRollupInfo,
StatementExtensionSvcContext statementExtensionSvcContext) |
SelectExprProcessorForge |
SelectExprProcessorRepresentationFactory.makeJoinWildcard(String[] streamNames,
EventType resultEventType,
EventAdapterService eventAdapterService) |
SelectExprProcessorForge |
SelectExprProcessorRepresentationFactory.makeRecast(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
AvroSchemaEventType insertIntoTargetType,
ExprNode[] exprNodes,
String statementName,
String engineURI) |
SelectExprProcessorForge |
SelectExprProcessorRepresentationFactory.makeSelectNoWildcard(SelectExprForgeContext selectExprForgeContext,
ExprForge[] exprForges,
EventType resultEventType,
TableService tableService,
String statementName,
String engineURI) |
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessor |
SelectExprProcessorCompiler.allocateSelectExprEvaluator(EventAdapterService eventAdapterService,
SelectExprProcessorForge forge,
EngineImportService engineImportService,
Class compiledByClass,
boolean onDemandQuery,
String statementName) |
static SelectExprProcessorCompilerResult |
SelectExprProcessorCompiler.generate(CodegenClassScope codegenClassScope,
SelectExprProcessorForge forge,
EngineImportService engineImportService,
EventAdapterService eventAdapterService) |
Constructor and Description |
---|
SelectExprJoinWildcardProcessorTableRows(EventType[] types,
SelectExprProcessorForge inner,
TableService tableService) |
SelectExprResultProcessor(StatementResultService statementResultService,
SelectExprProcessorForge syntheticProcessor,
BindProcessorForge bindProcessorForge)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessorForge |
EvalSelectStreamWUndRecastObjectArrayFactory.make(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService,
String statementName,
String engineURI) |
static SelectExprProcessorForge |
EvalSelectStreamWUndRecastMapFactory.make(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService,
String statementName,
String engineURI) |
Constructor and Description |
---|
EvalInsertWildcardJoin(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType,
SelectExprProcessorForge joinWildcardProcessorForge) |
EvalInsertWildcardJoinRevision(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType,
SelectExprProcessorForge joinWildcardProcessorForge,
ValueAddEventProcessor vaeProcessor) |
EvalSelectWildcardJoin(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType,
SelectExprProcessorForge joinWildcardProcessorForge) |