Constructor and Description |
---|
ViewableActivatorNamedWindowForge(NamedWindowConsumerStreamSpec spec,
NamedWindowMetaData namedWindow,
ExprNode filterEvaluator,
QueryGraphForge filterQueryGraph,
boolean subquery,
PropertyEvaluatorForge optPropertyEvaluator) |
Modifier and Type | Method and Description |
---|---|
void |
FilterExprAnalyzerDTIntervalAffector.apply(QueryGraphForge filterQueryGraph) |
void |
FilterExprAnalyzerDTBetweenAffector.apply(QueryGraphForge queryGraph) |
Modifier and Type | Field and Description |
---|---|
protected QueryGraphForge |
FAFQueryMethodIUDBaseForge.queryGraph |
Modifier and Type | Method and Description |
---|---|
QueryGraphForge |
FAFQueryMethodSelectDesc.getQueryGraph() |
Constructor and Description |
---|
HistoricalStreamIndexListForge(int historicalStreamNum,
EventType[] typesPerStream,
QueryGraphForge queryGraph)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
FilterExprAnalyzerAffectorIndexProvision.apply(QueryGraphForge queryGraph) |
Modifier and Type | Method and Description |
---|---|
static QueryGraphForge |
OuterJoinAnalyzer.analyze(OuterJoinDesc[] outerJoinDescList,
QueryGraphForge queryGraph)
Analyzes the outer join descriptor list to build a query graph model.
|
Modifier and Type | Method and Description |
---|---|
static void |
FilterExprAnalyzer.analyze(ExprNode topNode,
QueryGraphForge queryGraph,
boolean isOuterJoin)
Analyzes filter expression to build query graph model.
|
static QueryGraphForge |
OuterJoinAnalyzer.analyze(OuterJoinDesc[] outerJoinDescList,
QueryGraphForge queryGraph)
Analyzes the outer join descriptor list to build a query graph model.
|
protected static void |
FilterExprAnalyzer.analyzeAndNode(ExprAndNode andNode,
QueryGraphForge queryGraph,
boolean isOuterJoin)
Analyze the AND-node.
|
protected static void |
FilterExprAnalyzer.analyzeEqualsNode(ExprEqualsNode equalsNode,
QueryGraphForge queryGraph,
boolean isOuterJoin)
Analye EQUALS (=) node.
|
static void |
RangeFilterAnalyzer.apply(ExprNode target,
ExprNode start,
ExprNode end,
boolean includeStart,
boolean includeEnd,
boolean isNot,
QueryGraphForge queryGraph) |
void |
FilterExprAnalyzerAffector.apply(QueryGraphForge queryGraph) |
Modifier and Type | Method and Description |
---|---|
static Pair<HistoricalIndexLookupStrategyForge,PollResultIndexingStrategyForge> |
JoinSetComposerPrototypeForgeFactory.determineIndexing(QueryGraphForge queryGraph,
EventType polledViewType,
EventType streamViewType,
int polledViewStreamNum,
int streamViewStreamNum)
Constructs indexing and lookup strategy for a given relationship that a historical stream may have with another
stream (historical or not) that looks up into results of a poll of a historical stream.
|
Modifier and Type | Method and Description |
---|---|
static void |
QueryGraphForge.fillEquivalentNav(EventType[] typesPerStream,
QueryGraphForge queryGraph)
Fill in equivalent key properties (navigation entries) on all streams.
|
Modifier and Type | Method and Description |
---|---|
static QueryPlanForge |
TwoStreamQueryPlanBuilder.build(EventType[] typesPerStream,
QueryGraphForge queryGraph,
OuterJoinType optionalOuterJoinType,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult)
Build query plan.
|
protected static QueryPlanForge |
NStreamQueryPlanBuilder.build(QueryGraphForge queryGraph,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
boolean hasForceNestedIter,
String[][][] indexedStreamsUniqueProps,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult) |
protected static QueryPlanForge |
NStreamOuterQueryPlanBuilder.build(QueryGraphForge queryGraph,
OuterJoinDesc[] outerJoinDescList,
String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
String[][][] indexedStreamsUniqueProps,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services) |
static QueryPlanIndexForge[] |
QueryPlanIndexBuilder.buildIndexSpec(QueryGraphForge queryGraph,
EventType[] typePerStream,
String[][][] indexedStreamsUniqueProps)
Build index specification from navigability info.
|
protected static NStreamQueryPlanBuilder.BestChainResult |
NStreamQueryPlanBuilder.computeBestPath(int lookupStream,
QueryGraphForge queryGraph,
DependencyGraph dependencyGraph)
Compute a best chain or path for lookups to take for the lookup stream passed in and the query
property relationships.
|
protected static int |
NStreamQueryPlanBuilder.computeNavigableDepth(int lookupStream,
int[] nextStreams,
QueryGraphForge queryGraph)
Given a chain of streams to look up and indexing information, compute the index within the
chain of the first non-index lookup.
|
static TableLookupPlanForge |
NStreamQueryPlanBuilder.createLookupPlan(QueryGraphForge queryGraph,
int currentLookupStream,
int indexedStream,
boolean indexedStreamIsVDW,
QueryPlanIndexForge 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 QueryPlanNodeForge |
NStreamQueryPlanBuilder.createStreamPlan(int lookupStream,
int[] bestChain,
QueryGraphForge queryGraph,
QueryPlanIndexForge[] indexSpecsPerStream,
EventType[] typesPerStream,
boolean[] isHistorical,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult)
Walks the chain of lookups and constructs lookup strategy and plan specification based
on the index specifications.
|
static QueryPlanForge |
QueryPlanBuilder.getPlan(EventType[] typesPerStream,
OuterJoinDesc[] outerJoinDescList,
QueryGraphForge queryGraph,
String[] streamNames,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult,
boolean isQueryPlanLogging,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services) |
protected static void |
NStreamOuterQueryPlanBuilder.recursiveBuild(int streamNum,
Stack<Integer> streamCallStack,
QueryGraphForge queryGraph,
OuterInnerDirectionalGraph outerInnerGraph,
InnerJoinGraph innerJoinGraph,
Set<Integer> completedStreams,
LinkedHashMap<Integer,int[]> substreamsPerStream,
boolean[] requiredPerStream,
DependencyGraph dependencyGraph)
Recusivly builds a substream-per-stream ordered tree graph using the
join information supplied for outer joins and from the query graph (where clause).
|
protected static void |
NStreamOuterQueryPlanBuilder.recursiveBuildInnerJoin(int streamNum,
Stack<Integer> streamCallStack,
QueryGraphForge queryGraph,
Set<Integer> completedStreams,
LinkedHashMap<Integer,int[]> substreamsPerStream,
DependencyGraph dependencyGraph)
Recusivly builds a substream-per-stream ordered tree graph using the
join information supplied for outer joins and from the query graph (where clause).
|
Constructor and Description |
---|
SubSelectStrategyFactoryLocalViewPreloadedForge(List<ViewFactoryForge> viewForges,
ViewResourceDelegateDesc viewResourceDelegateDesc,
Pair<EventTableFactoryFactoryForge,SubordTableLookupStrategyFactoryForge> lookupStrategy,
ExprNode filterExprNode,
boolean correlatedSubquery,
AggregationServiceForgeDesc aggregationServiceForgeDesc,
int subqueryNumber,
ExprNode[] groupKeys,
NamedWindowMetaData namedWindow,
ExprNode namedWindowFilterExpr,
QueryGraphForge namedWindowFilterQueryGraph) |
Modifier and Type | Method and Description |
---|---|
static QueryGraphForge |
EPLValidationUtil.validateFilterGetQueryGraphSafe(ExprNode filterExpression,
StreamTypeServiceImpl typeService,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services) |
Modifier and Type | Method and Description |
---|---|
static void |
EPLValidationUtil.validateFilterWQueryGraphSafe(QueryGraphForge queryGraph,
ExprNode filterExpression,
StreamTypeServiceImpl typeService,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services) |
Copyright © 2005–2018. All rights reserved.