Package | Description |
---|---|
com.espertech.esper.epl.core |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
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.pollindex |
Poll result indexing strategies.
|
com.espertech.esper.epl.join.table |
Indexes for views
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
Modifier and Type | Method and Description |
---|---|
EventTable[][] |
MethodPollingViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
EventTable[][] |
DatabasePollingViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext) |
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 | Class and Description |
---|---|
class |
PollResultIndexingStrategyComposite
Strategy for building an index out of poll-results knowing the properties to base the index on.
|
class |
PollResultIndexingStrategyIndex
Strategy for building an index out of poll-results knowing the properties to base the index on.
|
class |
PollResultIndexingStrategyIndexCoerce
Strategy for building an index out of poll-results knowing the properties to base the index on, and their
coercion types.
|
class |
PollResultIndexingStrategyIndexCoerceSingle
Strategy for building an index out of poll-results knowing the properties to base the index on, and their
coercion types.
|
class |
PollResultIndexingStrategyIndexSingle
Strategy for building an index out of poll-results knowing the properties to base the index on.
|
class |
PollResultIndexingStrategyIndexSingleArray
Strategy for building an index out of poll-results knowing the properties to base the index on.
|
class |
PollResultIndexingStrategyNoIndex
Strategy of indexing that simply builds an unindexed table of poll results.
|
class |
PollResultIndexingStrategySorted
Strategy for building an index out of poll-results knowing the properties to base the index on.
|
Modifier and Type | Method and Description |
---|---|
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> |
HistoricalStreamIndexList.getStrategy(int streamViewStreamNum)
Get the strategies to use for polling from a given stream.
|
Modifier and Type | Method and Description |
---|---|
EventTable[][] |
HistoricalEventViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext)
Poll for stored historical or reference data using events per stream and
returing for each event-per-stream row a separate list with events
representing the poll result.
|