Package | Description |
---|---|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
Constructor and Description |
---|
JoinSetComposerPrototypeImpl(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
Annotation[] annotations,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
QueryPlanIndex[] indexSpecs,
QueryPlan queryPlan,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean joinRemoveStream,
boolean isOuterJoins,
TableService tableService,
EventTableIndexService eventTableIndexService,
EngineImportService engineImportService,
boolean isFireAndForget) |
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
static QueryPlan |
QueryPlanBuilder.getPlan(EventType[] typesPerStream,
OuterJoinDesc[] outerJoinDescList,
QueryGraph queryGraph,
String[] streamNames,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean isQueryPlanLogging,
Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext,
EngineImportService engineImportService,
boolean isFireAndForget)
Build query plan using the filter.
|
LookupInstructionExec |
LookupInstructionPlan.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal)
Constructs the executable from the plan.
|
ExecNode |
TableOuterLookupNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
TableLookupNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeNoOp.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeAllUnidirectionalOuter.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
abstract ExecNode |
QueryPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks)
Make execution node from this specification.
|
ExecNode |
NestedIterationNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexList,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
LookupInstructionQueryPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
HistoricalDataPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
HistoricalTableLookupStrategy |
HistoricalDataPlanNode.makeOuterJoinStategy(Viewable[] streamViews,
int pollingStreamNum,
HistoricalStreamIndexList[] historicalStreamIndexLists)
Returns the table lookup strategy for use in outer joins.
|