com.espertech.esper.epl.join.table
Class HistoricalStreamIndexList

java.lang.Object
  com.espertech.esper.epl.join.table.HistoricalStreamIndexList

public class HistoricalStreamIndexList
extends java.lang.Object

Manages index-building and sharing for historical streams by collecting required indexes during the query planning phase, and by providing the right lookup strategy and indexing strategy during query execution node creation.

Constructor Summary

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

Method Summary

void	addIndex(int streamViewStreamNum) Used during query plan phase to indicate that an index must be provided for use in lookup of historical events by using a stream's events.
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy>	getStrategy(int streamViewStreamNum) Get the strategies to use for polling from a given stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

HistoricalStreamIndexList

public HistoricalStreamIndexList(int historicalStreamNum,
                                 EventType[] typesPerStream,
                                 QueryGraph queryGraph)

Ctor.

Parameters:

historicalStreamNum - number of the historical stream

typesPerStream - event types for each stream

queryGraph - relationship between key and index properties

Method Detail

addIndex

public void addIndex(int streamViewStreamNum)

Used during query plan phase to indicate that an index must be provided for use in lookup of historical events by using a stream's events.

Parameters:

streamViewStreamNum - the stream providing lookup events

getStrategy

public Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> getStrategy(int streamViewStreamNum)

Get the strategies to use for polling from a given stream.

Parameters:

streamViewStreamNum - the stream providing the polling events

Returns:

looking and indexing strategy