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 |
---|---|
static QueryPlanIndex[] |
QueryPlanIndexBuilder.buildIndexSpec(QueryGraph queryGraph,
EventType[] typePerStream,
String[][][] indexedStreamsUniqueProps)
Build index specification from navigability info.
|
QueryPlanIndex[] |
QueryPlan.getIndexSpecs()
Return index specs.
|
static QueryPlanIndex |
QueryPlanIndex.makeIndex(List<QueryPlanIndexItem> indexesSet) |
static QueryPlanIndex |
QueryPlanIndex.makeIndex(QueryPlanIndexItem... items) |
static QueryPlanIndex |
QueryPlanIndex.makeIndexTableAccess(TableLookupIndexReqKey indexName) |
Modifier and Type | Method and Description |
---|---|
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.
|
static String |
QueryPlanIndex.print(QueryPlanIndex[] indexSpecs)
Print index specifications in readable format.
|
Constructor and Description |
---|
QueryPlan(QueryPlanIndex[] indexSpecs,
QueryPlanNode[] execNodeSpecs)
Ctor.
|