|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.join.base.JoinSetComposerPrototypeFactory
public class JoinSetComposerPrototypeFactory
Factory for building a JoinSetComposer
from analyzing filter nodes, for
fast join tuple result set composition.
Constructor Summary | |
---|---|
JoinSetComposerPrototypeFactory()
|
Method Summary | |
---|---|
static Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> |
determineIndexing(QueryGraph 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. |
static JoinSetComposerPrototype |
makeComposerPrototype(java.lang.String statementName,
java.lang.String statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
java.lang.String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery)
Builds join tuple composer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JoinSetComposerPrototypeFactory()
Method Detail |
---|
public static JoinSetComposerPrototype makeComposerPrototype(java.lang.String statementName, java.lang.String statementId, OuterJoinDesc[] outerJoinDescList, ExprNode optionalFilterNode, EventType[] streamTypes, java.lang.String[] streamNames, StreamJoinAnalysisResult streamJoinAnalysisResult, boolean queryPlanLogging, StatementContext statementContext, HistoricalViewableDesc historicalViewableDesc, ExprEvaluatorContext exprEvaluatorContext, boolean selectsRemoveStream, boolean hasAggregations, TableService tableService, boolean isOnDemandQuery) throws ExprValidationException
outerJoinDescList
- - list of descriptors for outer join criteriaoptionalFilterNode
- - filter tree for analysis to build indexes for fast accessstreamTypes
- - types of streamsstreamNames
- - names of streams
ExprValidationException
- is thrown to indicate that
validation of view use in joins failed.public static Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> determineIndexing(QueryGraph queryGraph, EventType polledViewType, EventType streamViewType, int polledViewStreamNum, int streamViewStreamNum)
The term "polled" refers to the assumed-historical stream.
queryGraph
- relationship representation of where-clause filter and outer join on-expressionspolledViewType
- the event type of the historical that is indexedstreamViewType
- the event type of the stream looking up in indexespolledViewStreamNum
- the stream number of the historical that is indexedstreamViewStreamNum
- the stream number of the historical that is looking up
|
© 2006-2015 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |