Package | Description |
---|---|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.agg.access |
State multifunction aggregation methods
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
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.core.eval |
Select expression evaluators.
|
com.espertech.esper.epl.enummethod.dot |
Enumeration method utility classes and input data sources.
|
com.espertech.esper.epl.expression.core |
Core expression classes.
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.expression.table |
Table access and identifiers expressions.
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.spec |
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.table.merge |
Table on-merge handlers.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
com.espertech.esper.epl.table.upd |
Table update strategies.
|
Modifier and Type | Method and Description |
---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.createTable(TableMetadata metadata,
ExprEvaluator[] optionalTableFilters) |
ViewableActivator |
ViewableActivatorFactory.createTable(TableMetadata metadata,
ExprEvaluator[] optionalTableFilters) |
Constructor and Description |
---|
ViewableActivatorTable(TableMetadata tableMetadata,
ExprEvaluator[] optionalTableFilters) |
Constructor and Description |
---|
StatementAgentInstanceFactoryCreateTable(TableMetadata tableMetadata) |
StatementAgentInstanceFactoryOnTriggerTable(StatementContext statementContext,
StatementSpecCompiled statementSpec,
EPServicesContext services,
ViewableActivator activator,
SubSelectStrategyCollection subSelectStrategyCollection,
ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
ExprNode validatedJoin,
TableOnViewFactory onExprFactory,
EventType activatorResultEventType,
TableMetadata tableMetadata,
ResultSetProcessorFactoryDesc outputResultSetProcessorPrototype,
OutputProcessViewFactory outputProcessViewFactory) |
Constructor and Description |
---|
SubSelectStrategyFactoryIndexShare(String statementName,
int statementId,
int subqueryNum,
EventType[] outerEventTypesSelect,
NamedWindowProcessor optionalNamedWindowProcessor,
TableMetadata optionalTableMetadata,
boolean fullTableScan,
IndexHint optionalIndexHint,
SubordPropPlan joinedPropPlan,
ExprEvaluator filterExprEval,
AggregationServiceFactoryDesc aggregationServiceFactory,
ExprEvaluator[] groupByKeys,
TableService tableService,
Annotation[] annotations,
StatementStopService statementStopService,
EngineImportService engineImportService) |
Modifier and Type | Method and Description |
---|---|
TableMetadata[] |
StreamJoinAnalysisResult.getTablesPerStream() |
Modifier and Type | Method and Description |
---|---|
void |
StreamJoinAnalysisResult.setTablesForStream(int streamNum,
TableMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
TableMetadata |
FireAndForgetProcessorTable.getTableMetadata() |
Constructor and Description |
---|
EPStatementDestroyCallbackTableIdxRef(TableService tableService,
TableMetadata tableMetadata,
String statementName) |
EPStatementDestroyCallbackTableUpdStr(TableService tableService,
TableMetadata tableMetadata,
String statementName) |
FireAndForgetProcessorTable(TableService tableService,
TableMetadata tableMetadata) |
Constructor and Description |
---|
AggregationAccessorMinMaxByTable(boolean max,
TableMetadata tableMetadata) |
AggregationAccessorSortedTable(boolean max,
Class componentType,
TableMetadata tableMetadata) |
Modifier and Type | Field and Description |
---|---|
protected TableMetadata |
AggSvcGroupByWTableBase.tableMetadata |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
Modifier and Type | Field and Description |
---|---|
protected TableMetadata |
SelectExprProcessorEnumerationAtBeanCollTableForge.tableMetadata |
Constructor and Description |
---|
BindProcessorEvaluatorStreamTable(int streamNum,
Class returnType,
TableMetadata tableMetadata) |
SelectExprProcessorEnumerationAtBeanCollTableForge(ExprEnumerationForge enumerationForge,
TableMetadata tableMetadata) |
SelectExprProcessorEvalStreamInsertTable(int streamNum,
ExprStreamUnderlyingNode undNode,
TableMetadata tableMetadata,
Class returnType) |
Constructor and Description |
---|
EvalSelectStreamWUnderlying(SelectExprContext selectExprContext,
EventType resultEventType,
List<SelectClauseStreamCompiledSpec> namedStreams,
boolean usingWildcard,
List<SelectExprStreamDesc> unnamedStreams,
boolean singleStreamWrapper,
boolean underlyingIsFragmentEvent,
int underlyingStreamNumber,
EventPropertyGetter underlyingPropertyEventGetter,
ExprEvaluator underlyingExprEvaluator,
TableMetadata tableMetadata) |
Constructor and Description |
---|
ExprDotForgeUnpackBeanTable(EventType lambdaType,
TableMetadata tableMetadata) |
ExprDotForgeUnpackCollEventBeanTable(EventType type,
TableMetadata tableMetadata) |
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ExprNodeUtility.makeUnderlyingEvaluator(int streamNum,
Class resultType,
TableMetadata tableMetadata) |
Constructor and Description |
---|
ExprNodeUtilExprStreamNumEventTable(int streamNum,
TableMetadata tableMetadata) |
ExprNodeUtilUnderlyingEvaluatorTable(int streamNum,
Class resultType,
TableMetadata tableMetadata) |
Constructor and Description |
---|
SubselectEvalStrategyRowFilteredUnselectedTable(TableMetadata tableMetadata) |
SubselectEvalStrategyRowUnfilteredUnselectedTable(TableMetadata tableMetadata) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExprTableAccessNodeTopLevel.validateBindingInternal(ExprValidationContext validationContext,
TableMetadata tableMetadata) |
protected void |
ExprTableAccessNodeSubpropAccessor.validateBindingInternal(ExprValidationContext validationContext,
TableMetadata tableMetadata) |
protected void |
ExprTableAccessNodeSubprop.validateBindingInternal(ExprValidationContext validationContext,
TableMetadata tableMetadata) |
protected void |
ExprTableAccessNodeKeys.validateBindingInternal(ExprValidationContext validationContext,
TableMetadata tableMetadata) |
protected abstract void |
ExprTableAccessNode.validateBindingInternal(ExprValidationContext validationContext,
TableMetadata tableMetadata) |
protected void |
ExprTableAccessNode.validateGroupKeys(TableMetadata metadata,
ExprValidationContext validationContext) |
protected TableMetadataColumn |
ExprTableAccessNode.validateSubpropertyGetCol(TableMetadata tableMetadata,
String subpropName) |
Modifier and Type | Method and Description |
---|---|
static QueryPlan |
TwoStreamQueryPlanBuilder.build(EventType[] typesPerStream,
QueryGraph queryGraph,
OuterJoinType optionalOuterJoinType,
String[][][] uniqueIndexProps,
TableMetadata[] tablesPerStream)
Build query plan.
|
protected static QueryPlan |
NStreamQueryPlanBuilder.build(QueryGraph queryGraph,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean hasForceNestedIter,
String[][][] indexedStreamsUniqueProps,
TableMetadata[] tablesPerStream) |
protected static QueryPlan |
NStreamOuterQueryPlanBuilder.build(QueryGraph queryGraph,
OuterJoinDesc[] outerJoinDescList,
String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
ExprEvaluatorContext exprEvaluatorContext,
String[][][] indexedStreamsUniqueProps,
TableMetadata[] tablesPerStream,
EngineImportService engineImportService,
boolean isFireAndForget)
Build a query plan based on the stream property relationships indicated in queryGraph.
|
static TableLookupPlan |
NStreamQueryPlanBuilder.createLookupPlan(QueryGraph queryGraph,
int currentLookupStream,
int indexedStream,
QueryPlanIndex indexSpecs,
EventType[] typesPerStream,
TableMetadata indexedStreamTableMeta)
Create the table lookup plan for a from-stream to look up in an indexed stream
using the columns supplied in the query graph and looking at the actual indexes available
and their index number.
|
protected static QueryPlanNode |
NStreamQueryPlanBuilder.createStreamPlan(int lookupStream,
int[] bestChain,
QueryGraph queryGraph,
QueryPlanIndex[] indexSpecsPerStream,
EventType[] typesPerStream,
boolean[] isHistorical,
HistoricalStreamIndexList[] historicalStreamIndexLists,
TableMetadata[] tablesPerStream)
Walks the chain of lookups and constructs lookup strategy and plan specification based
on the index specifications.
|
Modifier and Type | Method and Description |
---|---|
TableMetadata |
SelectClauseStreamCompiledSpec.getTableMetadata() |
Modifier and Type | Method and Description |
---|---|
void |
SelectClauseStreamCompiledSpec.setTableMetadata(TableMetadata tableMetadata) |
Constructor and Description |
---|
TableOnMergeHelper(StatementContext statementContext,
OnTriggerMergeDesc onTriggerDesc,
EventType triggeringEventType,
String triggeringStreamName,
InternalEventRouter internalEventRouter,
TableMetadata tableMetadata) |
Modifier and Type | Field and Description |
---|---|
protected TableMetadata |
TableStateInstance.tableMetadata |
Modifier and Type | Method and Description |
---|---|
TableMetadata |
TableServiceImpl.addTable(String tableName,
String eplExpression,
String statementName,
Class[] keyTypes,
Map<String,TableMetadataColumn> tableColumns,
TableStateRowFactory tableStateRowFactory,
int numberMethodAggregations,
StatementContext statementContext,
ObjectArrayEventType internalEventType,
ObjectArrayEventType publicEventType,
TableMetadataInternalEventToPublic eventToPublic,
boolean queryPlanLogging) |
TableMetadata |
TableService.addTable(String tableName,
String eplExpression,
String statementName,
Class[] keyTypes,
Map<String,TableMetadataColumn> tableColumns,
TableStateRowFactory tableStateRowFactory,
int numberMethodAggregations,
StatementContext statementContext,
ObjectArrayEventType internalEventType,
ObjectArrayEventType publicEventType,
TableMetadataInternalEventToPublic eventToPublic,
boolean queryPlanLogging) |
TableMetadata |
TableStateInstance.getTableMetadata() |
TableMetadata |
TableServiceImpl.getTableMetadata(String tableName) |
TableMetadata |
TableService.getTableMetadata(String tableName) |
TableMetadata |
TableServiceImpl.getTableMetadataFromEventType(EventType type) |
TableMetadata |
TableService.getTableMetadataFromEventType(EventType type) |
Modifier and Type | Method and Description |
---|---|
void |
TableServiceImpl.addTableUpdateStrategyReceiver(TableMetadata tableMetadata,
String statementName,
TableUpdateStrategyReceiver receiver,
EventBeanUpdateHelper updateHelper,
boolean isOnMerge) |
void |
TableService.addTableUpdateStrategyReceiver(TableMetadata tableMetadata,
String statementName,
TableUpdateStrategyReceiver receiver,
EventBeanUpdateHelper updateHelper,
boolean isOnMerge) |
TableUpdateStrategy |
TableServiceImpl.getTableUpdateStrategy(TableMetadata tableMetadata,
EventBeanUpdateHelper updateHelper,
boolean isOnMerge) |
TableUpdateStrategy |
TableService.getTableUpdateStrategy(TableMetadata tableMetadata,
EventBeanUpdateHelper updateHelper,
boolean isOnMerge) |
void |
TableServiceImpl.removeIndexReferencesStmtMayRemoveIndex(String statementName,
TableMetadata tableMetadata) |
void |
TableService.removeIndexReferencesStmtMayRemoveIndex(String statementName,
TableMetadata tableMetadata) |
void |
TableServiceImpl.removeTableUpdateStrategyReceivers(TableMetadata tableMetadata,
String statementName) |
void |
TableService.removeTableUpdateStrategyReceivers(TableMetadata tableMetadata,
String statementName) |
void |
TableServiceImpl.validateAddIndex(String createIndexStatementName,
TableMetadata tableMetadata,
String explicitIndexName,
QueryPlanIndexItem explicitIndexDesc,
IndexMultiKey imk) |
void |
TableService.validateAddIndex(String createIndexStatementName,
TableMetadata tableMetadata,
String explicitIndexName,
QueryPlanIndexItem explicitIndexDesc,
IndexMultiKey imk) |
Constructor and Description |
---|
TableStateInstance(TableMetadata tableMetadata,
AgentInstanceContext agentInstanceContext) |
TableStateInstanceGroupedImpl(TableMetadata tableMetadata,
AgentInstanceContext agentInstanceContext) |
TableStateInstanceUngroupedImpl(TableMetadata tableMetadata,
AgentInstanceContext agentInstanceContext) |
TableStateViewableInternal(TableMetadata tableMetadata,
TableStateInstance tableStateInstance,
ExprEvaluator[] optionalTableFilters) |
TableStateViewablePublic(TableMetadata tableMetadata,
TableStateInstance tableStateInstance) |
Modifier and Type | Field and Description |
---|---|
protected TableMetadata |
TableOnViewBase.metadata |
Modifier and Type | Method and Description |
---|---|
TableMetadata |
TableOnUpdateViewFactory.getTableMetadata() |
TableMetadata |
TableOnMergeViewFactory.getTableMetadata() |
TableMetadata |
TableOnDeleteViewFactory.getTableMetadata() |
Modifier and Type | Method and Description |
---|---|
static TableOnViewFactory |
TableOnViewFactoryFactory.make(TableMetadata tableMetadata,
OnTriggerDesc onTriggerDesc,
EventType filterEventType,
String filterStreamName,
StatementContext statementContext,
StatementMetricHandle metricsHandle,
boolean isDistinct,
InternalEventRouter internalEventRouter) |
static EventBean[] |
TableOnViewUtil.toPublic(EventBean[] matching,
TableMetadata tableMetadata,
EventBean[] triggers,
boolean isNewData,
ExprEvaluatorContext context) |
Modifier and Type | Method and Description |
---|---|
static ExprTableAccessEvalStrategy |
ExprTableEvalStrategyFactory.getTableAccessEvalStrategy(ExprTableAccessNode tableNode,
TableAndLockProvider provider,
TableMetadata tableMetadata) |
Modifier and Type | Method and Description |
---|---|
static TableUpdateStrategy |
TableUpdateStrategyFactory.validateGetTableUpdateStrategy(TableMetadata tableMetadata,
EventBeanUpdateHelper updateHelper,
boolean isOnMerge) |