| Package | Description |
|---|---|
| com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
| com.espertech.esper.epl.join.exec.base |
Inner join execution
|
| com.espertech.esper.epl.join.table |
Indexes for views
|
| Modifier and Type | Class and Description |
|---|---|
class |
HistoricalIndexLookupStrategyComposite
Index lookup strategy into a poll-based cache result.
|
class |
HistoricalIndexLookupStrategyIndex
Index lookup strategy into a poll-based cache result.
|
class |
HistoricalIndexLookupStrategyIndexSingle
Index lookup strategy into a poll-based cache result.
|
class |
HistoricalIndexLookupStrategyInKeywordMulti
Index lookup strategy into a poll-based cache result.
|
class |
HistoricalIndexLookupStrategyInKeywordSingle
Index lookup strategy into a poll-based cache result.
|
class |
HistoricalIndexLookupStrategyNoIndex
Full table scan strategy for a poll-based cache result.
|
class |
HistoricalIndexLookupStrategySorted
Index lookup strategy into a poll-based cache result.
|
| 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.
|
| Constructor and Description |
|---|
HistoricalDataQueryStrategy(int myStreamNumber,
int historicalStreamNumber,
HistoricalEventViewable historicalEventViewable,
boolean isOuterJoin,
ExprEvaluator outerJoinCompareNode,
HistoricalIndexLookupStrategy indexLookupStrategy,
PollResultIndexingStrategy pollResultIndexingStrategy)
Ctor.
|
| Constructor and Description |
|---|
JoinSetComposerPrototypeHistorical2StreamImpl(ExprEvaluator optionalFilterEval,
EventType[] streamTypes,
ExprEvaluatorContext exprEvaluatorContext,
int polledViewNum,
int streamViewNum,
boolean outerJoin,
ExprEvaluator outerJoinEqualsEval,
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> indexStrategies,
boolean allHistoricalNoSubordinate,
OuterJoinDesc[] outerJoinDescList,
boolean allowIndexInit) |
| Constructor and Description |
|---|
HistoricalDataExecNode(HistoricalEventViewable historicalEventViewable,
PollResultIndexingStrategy indexingStrategy,
HistoricalIndexLookupStrategy indexLookupStrategy,
int numStreams,
int historicalStreamNumber)
Ctor.
|
HistoricalTableLookupStrategy(HistoricalEventViewable viewable,
PollResultIndexingStrategy indexingStrategy,
HistoricalIndexLookupStrategy lookupStrategy,
int numStreams,
int streamNum,
int rootStreamNum,
ExprEvaluator outerJoinExprNode)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> |
HistoricalStreamIndexList.getStrategy(int streamViewStreamNum)
Get the strategies to use for polling from a given stream.
|