com.espertech.esper.epl.join.base

Class HistoricalDataQueryStrategy

java.lang.Object

com.espertech.esper.epl.join.base.HistoricalDataQueryStrategy

All Implemented Interfaces:

QueryStrategy

public class HistoricalDataQueryStrategy
extends Object
implements QueryStrategy

Query strategy for use with HistoricalEventViewable to perform lookup for a given stream using the poll method on a viewable.

Constructor Summary

Constructors

Constructor and Description
HistoricalDataQueryStrategy(int myStreamNumber, int historicalStreamNumber, HistoricalEventViewable historicalEventViewable, boolean isOuterJoin, ExprEvaluator outerJoinCompareNode, HistoricalIndexLookupStrategy indexLookupStrategy, PollResultIndexingStrategy pollResultIndexingStrategy) Ctor.

Method Summary

Modifier and Type	Method and Description
void	lookup(EventBean[] lookupEvents, Set<MultiKey<EventBean>> joinSet, ExprEvaluatorContext exprEvaluatorContext) Look up events returning tuples of joined events.

Methods inherited from class java.lang.Object

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

Constructor Detail

HistoricalDataQueryStrategy

public HistoricalDataQueryStrategy(int myStreamNumber,
                                   int historicalStreamNumber,
                                   HistoricalEventViewable historicalEventViewable,
                                   boolean isOuterJoin,
                                   ExprEvaluator outerJoinCompareNode,
                                   HistoricalIndexLookupStrategy indexLookupStrategy,
                                   PollResultIndexingStrategy pollResultIndexingStrategy)

Ctor.

Parameters:

myStreamNumber - is the strategy's stream number

historicalStreamNumber - is the stream number of the view to be polled

historicalEventViewable - is the view to be polled from

isOuterJoin - is this is an outer join

outerJoinCompareNode - is the node to perform the on-comparison for outer joins

indexLookupStrategy - the strategy to use for limiting the cache result set to only those rows that match filter criteria

pollResultIndexingStrategy - the strategy for indexing poll-results such that a strategy can use the index instead of a full table scan to resolve rows

Method Detail

lookup

public void lookup(EventBean[] lookupEvents,
                   Set<MultiKey<EventBean>> joinSet,
                   ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: QueryStrategy

Look up events returning tuples of joined events.

Specified by:

lookup in interface QueryStrategy

Parameters:

lookupEvents - - events to use to perform the join

joinSet - - result join tuples of events

exprEvaluatorContext - expression evaluation context