Uses of Class
com.espertech.esper.epl.join.plan.QueryGraph

Packages that use QueryGraph

Package	Description
com.espertech.esper.core.context.factory	Statement agent instance factories.
com.espertech.esper.core.start	Classes related to start and stop of statements
com.espertech.esper.epl.datetime.eval	Date-Time methods and related utility classes.
com.espertech.esper.epl.expression.core	Core expression classes.
com.espertech.esper.epl.fafquery	Fire-and-forget query execution planning.
com.espertech.esper.epl.index.service	Advanced index provisioning
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
com.espertech.esper.epl.join.table	Indexes for views
com.espertech.esper.epl.join.util	Join-related utilities
com.espertech.esper.epl.named	Named window classes are in this package

Uses of QueryGraph in com.espertech.esper.core.context.factory

Constructors in com.espertech.esper.core.context.factory with parameters of type QueryGraph

Constructor and Description
StatementAgentInstancePostLoadSelect(Viewable[] streamViews, JoinSetComposerDesc joinSetComposer, NamedWindowTailViewInstance[] namedWindowTailViews, QueryGraph[] namedWindowPostloadFilters, List<ExprNode>[] namedWindowFilters, Annotation[] annotations, ExprEvaluatorContext exprEvaluatorContext)

Uses of QueryGraph in com.espertech.esper.core.start

Methods in com.espertech.esper.core.start that return QueryGraph

Modifier and Type	Method and Description
QueryGraph	EPPreparedExecuteIUDSingleStreamExecUpdate.getQueryGraph()
QueryGraph	EPPreparedExecuteIUDSingleStreamExecDelete.getQueryGraph()

Methods in com.espertech.esper.core.start with parameters of type QueryGraph

Modifier and Type	Method and Description
EPPreparedExecuteIUDSingleStreamExec	EPPreparedExecuteIUDSingleStreamUpdate.getExecutor(QueryGraph queryGraph, String aliasName)
EPPreparedExecuteIUDSingleStreamExec	EPPreparedExecuteIUDSingleStreamDelete.getExecutor(QueryGraph queryGraph, String aliasName)
abstract EPPreparedExecuteIUDSingleStreamExec	EPPreparedExecuteIUDSingleStream.getExecutor(QueryGraph queryGraph, String aliasName)
EPPreparedExecuteIUDSingleStreamExec	EPPreparedExecuteIUDInsertInto.getExecutor(QueryGraph queryGraph, String aliasName)
Collection<EventBean>	FireAndForgetInstanceTable.snapshotBestEffort(EPPreparedExecuteMethodQuery query, QueryGraph queryGraph, Annotation[] annotations)
Collection<EventBean>	FireAndForgetInstanceNamedWindow.snapshotBestEffort(EPPreparedExecuteMethodQuery query, QueryGraph queryGraph, Annotation[] annotations)
abstract Collection<EventBean>	FireAndForgetInstance.snapshotBestEffort(EPPreparedExecuteMethodQuery epPreparedExecuteMethodQuery, QueryGraph queryGraph, Annotation[] annotations)

Constructors in com.espertech.esper.core.start with parameters of type QueryGraph

Constructor and Description
EPPreparedExecuteIUDSingleStreamExecDelete(QueryGraph queryGraph, ExprNode optionalWhereClause, Annotation[] annotations, ExprTableAccessNode[] optionalTableNodes, EPServicesContext services)
EPPreparedExecuteIUDSingleStreamExecUpdate(QueryGraph queryGraph, ExprNode optionalWhereClause, Annotation[] annotations, EventBeanUpdateHelper updateHelper, TableUpdateStrategy tableUpdateStrategy, ExprTableAccessNode[] optionalTableNodes, EPServicesContext services)

Uses of QueryGraph in com.espertech.esper.epl.datetime.eval

Methods in com.espertech.esper.epl.datetime.eval with parameters of type QueryGraph

Modifier and Type	Method and Description
void	FilterExprAnalyzerDTIntervalAffector.apply(QueryGraph queryGraph)
void	FilterExprAnalyzerDTBetweenAffector.apply(QueryGraph queryGraph)

Uses of QueryGraph in com.espertech.esper.epl.expression.core

Methods in com.espertech.esper.epl.expression.core that return QueryGraph

Modifier and Type	Method and Description
static QueryGraph	ExprNodeUtility.validateFilterGetQueryGraphSafe(ExprNode filterExpression, StatementContext statementContext, StreamTypeServiceImpl typeService)

Methods in com.espertech.esper.epl.expression.core with parameters of type QueryGraph

Modifier and Type	Method and Description
static void	ExprNodeUtility.validateFilterWQueryGraphSafe(QueryGraph queryGraph, ExprNode filterExpression, StatementContext statementContext, StreamTypeServiceImpl typeService)

Uses of QueryGraph in com.espertech.esper.epl.fafquery

Methods in com.espertech.esper.epl.fafquery with parameters of type QueryGraph

Modifier and Type	Method and Description
static Collection<EventBean>	FireAndForgetQueryExec.snapshot(QueryGraph queryGraph, Annotation[] annotations, VirtualDWView virtualDataWindow, EventTableIndexRepository indexRepository, boolean queryPlanLogging, org.slf4j.Logger queryPlanLogDestination, String objectName, AgentInstanceContext agentInstanceContext)

Uses of QueryGraph in com.espertech.esper.epl.index.service

Methods in com.espertech.esper.epl.index.service with parameters of type QueryGraph

Modifier and Type	Method and Description
void	FilterExprAnalyzerAffectorIndexProvision.apply(QueryGraph queryGraph)

Uses of QueryGraph in com.espertech.esper.epl.join.base

Methods in com.espertech.esper.epl.join.base with parameters of type QueryGraph

Modifier and Type	Method and Description
static Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy>	JoinSetComposerPrototypeFactory.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.

Uses of QueryGraph in com.espertech.esper.epl.join.plan

Methods in com.espertech.esper.epl.join.plan that return QueryGraph

Modifier and Type	Method and Description
static QueryGraph	OuterJoinAnalyzer.analyze(OuterJoinDesc[] outerJoinDescList, QueryGraph queryGraph) Analyzes the outer join descriptor list to build a query graph model.

Methods in com.espertech.esper.epl.join.plan with parameters of type QueryGraph

Modifier and Type	Method and Description
static void	FilterExprAnalyzer.analyze(ExprNode topNode, QueryGraph queryGraph, boolean isOuterJoin) Analyzes filter expression to build query graph model.
static QueryGraph	OuterJoinAnalyzer.analyze(OuterJoinDesc[] outerJoinDescList, QueryGraph queryGraph) Analyzes the outer join descriptor list to build a query graph model.
protected static void	FilterExprAnalyzer.analyzeAndNode(ExprAndNode andNode, QueryGraph queryGraph, boolean isOuterJoin) Analyze the AND-node.
protected static void	FilterExprAnalyzer.analyzeEqualsNode(ExprEqualsNode equalsNode, QueryGraph queryGraph, boolean isOuterJoin) Analye EQUALS (=) node.
void	FilterExprAnalyzerAffector.apply(QueryGraph queryGraph)
static QueryPlan	TwoStreamQueryPlanBuilder.build(EventType[] typesPerStream, QueryGraph queryGraph, OuterJoinType optionalOuterJoinType, String[][][] uniqueIndexProps, TableMetadata[] tablesPerStream) Build query plan.
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.
static QueryPlanIndex[]	QueryPlanIndexBuilder.buildIndexSpec(QueryGraph queryGraph, EventType[] typePerStream, String[][][] indexedStreamsUniqueProps) Build index specification from navigability info.
protected static NStreamQueryPlanBuilder.BestChainResult	NStreamQueryPlanBuilder.computeBestPath(int lookupStream, QueryGraph 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, QueryGraph 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 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 void	QueryGraph.fillEquivalentNav(EventType[] typesPerStream, QueryGraph queryGraph) Fill in equivalent key properties (navigation entries) on all streams.
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.
protected static void	NStreamOuterQueryPlanBuilder.recursiveBuild(int streamNum, Stack<Integer> streamCallStack, QueryGraph 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, QueryGraph 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 QueryGraph in com.espertech.esper.epl.join.table

Constructors in com.espertech.esper.epl.join.table with parameters of type QueryGraph

Constructor and Description
HistoricalStreamIndexList(int historicalStreamNum, EventType[] typesPerStream, QueryGraph queryGraph) Ctor.

Uses of QueryGraph in com.espertech.esper.epl.join.util

Methods in com.espertech.esper.epl.join.util with parameters of type QueryGraph

Modifier and Type	Method and Description
static void	RangeFilterAnalyzer.apply(ExprNode target, ExprNode start, ExprNode end, boolean includeStart, boolean includeEnd, boolean isNot, QueryGraph queryGraph)

Uses of QueryGraph in com.espertech.esper.epl.named

Methods in com.espertech.esper.epl.named with parameters of type QueryGraph

Modifier and Type	Method and Description
Collection<EventBean>	NamedWindowTailViewInstance.snapshot(QueryGraph queryGraph, Annotation[] annotations) Returns a snapshot of window contents, thread-safely
Collection<EventBean>	NamedWindowRootViewInstance.snapshot(QueryGraph queryGraph, Annotation[] annotations) Return a snapshot using index lookup filters.
EventBean[]	NamedWindowTailViewInstance.snapshotDelete(QueryGraph queryGraph, ExprNode filterExpr, Annotation[] annotations)
Collection<EventBean>	NamedWindowTailViewInstance.snapshotNoLock(QueryGraph queryGraph, Annotation[] annotations)
Collection<EventBean>	NamedWindowTailViewInstance.snapshotNoLockWithFilter(QueryGraph queryGraph, Annotation[] annotations, ExprNode filterExpr, ExprEvaluatorContext exprEvaluatorContext)
EventBean[]	NamedWindowTailViewInstance.snapshotUpdate(QueryGraph queryGraph, ExprNode optionalWhereClause, EventBeanUpdateHelper updateHelper, Annotation[] annotations)