com.espertech.esper.epl.join.plan

Class HistoricalDataPlanNode

java.lang.Object

com.espertech.esper.epl.join.plan.QueryPlanNode

com.espertech.esper.epl.join.plan.HistoricalDataPlanNode

public class HistoricalDataPlanNode
extends QueryPlanNode

Query plan for performing a historical data lookup.

Translates into a particular execution for use in regular and outer joins.

Constructor Summary

Constructors

Constructor and Description
HistoricalDataPlanNode(int streamNum, int rootStreamNum, int lookupStreamNum, int numStreams, ExprEvaluator outerJoinExprEval) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)
ExecNode	makeExec(java.lang.String statementName, int statementId, java.lang.annotation.Annotation[] annotations, java.util.Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream, EventType[] streamTypes, Viewable[] streamViews, HistoricalStreamIndexList[] historicalStreamIndexLists, VirtualDWView[] viewExternal, java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks) Make execution node from this specification.
HistoricalTableLookupStrategy	makeOuterJoinStategy(Viewable[] streamViews, int pollingStreamNum, HistoricalStreamIndexList[] historicalStreamIndexLists) Returns the table lookup strategy for use in outer joins.
protected void	print(IndentWriter writer) Print a long readable format of the query node to the supplied PrintWriter.

Methods inherited from class com.espertech.esper.epl.join.plan.QueryPlanNode

print

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HistoricalDataPlanNode

public HistoricalDataPlanNode(int streamNum,
                              int rootStreamNum,
                              int lookupStreamNum,
                              int numStreams,
                              ExprEvaluator outerJoinExprEval)

Ctor.

Parameters:

streamNum - the historical stream num

rootStreamNum - the stream number of the query plan providing incoming events

lookupStreamNum - the stream that provides polling/lookup events

numStreams - number of streams in join

outerJoinExprEval - outer join expression node or null if none defined

Method Detail

makeExec

public ExecNode makeExec(java.lang.String statementName,
                         int statementId,
                         java.lang.annotation.Annotation[] annotations,
                         java.util.Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
                         EventType[] streamTypes,
                         Viewable[] streamViews,
                         HistoricalStreamIndexList[] historicalStreamIndexLists,
                         VirtualDWView[] viewExternal,
                         java.util.concurrent.locks.Lock[] tableSecondaryIndexLocks)

Description copied from class: QueryPlanNode

Make execution node from this specification.

Specified by:

makeExec in class QueryPlanNode

Parameters:

statementName - statement name

statementId - statement id

annotations - annotations

indexesPerStream - - tables build for each stream

streamTypes - - event type of each stream

streamViews - - viewable per stream for access to historical data

historicalStreamIndexLists - index management for historical streams

viewExternal - view

tableSecondaryIndexLocks - locks

Returns:

execution node matching spec

addIndexes

public void addIndexes(java.util.HashSet<TableLookupIndexReqKey> usedIndexes)

Specified by:

addIndexes in class QueryPlanNode

makeOuterJoinStategy

public HistoricalTableLookupStrategy makeOuterJoinStategy(Viewable[] streamViews,
                                                          int pollingStreamNum,
                                                          HistoricalStreamIndexList[] historicalStreamIndexLists)

Returns the table lookup strategy for use in outer joins.

Parameters:

streamViews - all views in join

pollingStreamNum - the stream number of the stream looking up into the historical

historicalStreamIndexLists - the index management for the historical stream

Returns:

strategy

print

protected void print(IndentWriter writer)

Description copied from class: QueryPlanNode

Print a long readable format of the query node to the supplied PrintWriter.

Specified by:

print in class QueryPlanNode

Parameters:

writer - is the indentation writer to print to