Uses of Class
com.espertech.esper.common.internal.epl.join.querygraph.QueryGraphForge
Package
Description
Date-Time methods and related utility classes.
Advanced index provisioning
-
Uses of QueryGraphForge in com.espertech.esper.common.internal.context.activator
ModifierConstructorDescriptionViewableActivatorNamedWindowForge
(NamedWindowConsumerStreamSpec spec, NamedWindowMetaData namedWindow, ExprNode filterEvaluator, QueryGraphForge filterQueryGraph, boolean subquery, PropertyEvaluatorForge optPropertyEvaluator) -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.datetime.eval
Modifier and TypeMethodDescriptionvoid
FilterExprAnalyzerDTBetweenAffector.apply
(QueryGraphForge queryGraph) void
FilterExprAnalyzerDTIntervalAffector.apply
(QueryGraphForge filterQueryGraph) -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.fafquery.querymethod
Modifier and TypeFieldDescriptionprotected final QueryGraphForge
FAFQueryMethodIUDBaseForge.queryGraph
-
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.historical.common
ModifierConstructorDescriptionHistoricalStreamIndexListForge
(int historicalStreamNum, EventType[] typesPerStream, QueryGraphForge queryGraph) Ctor. -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.index.advanced.index.service
Modifier and TypeMethodDescriptionvoid
FilterExprAnalyzerAffectorIndexProvision.apply
(QueryGraphForge queryGraph) -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.join.analyze
Modifier and TypeMethodDescriptionstatic QueryGraphForge
OuterJoinAnalyzer.analyze
(OuterJoinDesc[] outerJoinDescList, QueryGraphForge queryGraph) Analyzes the outer join descriptor list to build a query graph model.Modifier and TypeMethodDescriptionstatic 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.void
FilterExprAnalyzerAffector.apply
(QueryGraphForge queryGraph) static void
RangeFilterAnalyzer.apply
(ExprNode target, ExprNode start, ExprNode end, boolean includeStart, boolean includeEnd, boolean isNot, QueryGraphForge queryGraph) -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.join.base
Modifier and TypeMethodDescriptionJoinSetComposerPrototypeForgeFactory.determineIndexing
(QueryGraphForge queryGraph, EventType polledViewType, EventType streamViewType, int polledViewStreamNum, int streamViewStreamNum, StatementRawInfo raw, SerdeCompileTimeResolver serdeResolver) 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. -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.join.querygraph
Modifier and TypeMethodDescriptionstatic void
QueryGraphForge.fillEquivalentNav
(EventType[] typesPerStream, QueryGraphForge queryGraph) Fill in equivalent key properties (navigation entries) on all streams. -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.join.queryplanbuild
Modifier and TypeMethodDescriptionprotected static QueryPlanForgeDesc
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) protected static QueryPlanForgeDesc
NStreamQueryPlanBuilder.build
(QueryGraphForge queryGraph, EventType[] typesPerStream, HistoricalViewableDesc historicalViewableDesc, DependencyGraph dependencyGraph, HistoricalStreamIndexListForge[] historicalStreamIndexLists, boolean hasForceNestedIter, String[][][] indexedStreamsUniqueProps, TableMetaData[] tablesPerStream, StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult, StatementRawInfo raw, SerdeCompileTimeResolver serdeResolver) static QueryPlanForgeDesc
TwoStreamQueryPlanBuilder.build
(EventType[] typesPerStream, QueryGraphForge queryGraph, OuterJoinType optionalOuterJoinType, StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult, StatementRawInfo raw) Build query plan.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 TableLookupPlanDesc
NStreamQueryPlanBuilder.createLookupPlan
(QueryGraphForge queryGraph, int currentLookupStream, int indexedStream, boolean indexedStreamIsVDW, QueryPlanIndexForge indexSpecs, EventType[] typesPerStream, TableMetaData indexedStreamTableMeta, StatementRawInfo raw, SerdeCompileTimeResolver serdeResolver) 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 QueryPlanNodeForgeDesc
NStreamQueryPlanBuilder.createStreamPlan
(int lookupStream, int[] bestChain, QueryGraphForge queryGraph, QueryPlanIndexForge[] indexSpecsPerStream, EventType[] typesPerStream, boolean[] isHistorical, HistoricalStreamIndexListForge[] historicalStreamIndexLists, TableMetaData[] tablesPerStream, StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult, StatementRawInfo raw, SerdeCompileTimeResolver serdeResolver) Walks the chain of lookups and constructs lookup strategy and plan specification based on the index specifications.static QueryPlanForgeDesc
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). -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.subselect
ModifierConstructorDescriptionSubSelectStrategyFactoryLocalViewPreloadedForge
(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, MultiKeyClassRef groupByMultiKeyClasses, boolean isTargetHA) -
Uses of QueryGraphForge in com.espertech.esper.common.internal.epl.util
Modifier and TypeMethodDescriptionstatic QueryGraphForge
EPLValidationUtil.validateFilterGetQueryGraphSafe
(ExprNode filterExpression, StreamTypeServiceImpl typeService, StatementRawInfo statementRawInfo, StatementCompileTimeServices services) Modifier and TypeMethodDescriptionstatic void
EPLValidationUtil.validateFilterWQueryGraphSafe
(QueryGraphForge queryGraph, ExprNode filterExpression, StreamTypeServiceImpl typeService, StatementRawInfo statementRawInfo, StatementCompileTimeServices services)