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.plan |
Inner join and outer join query planning
|
Modifier and Type | Method and Description |
---|---|
protected ExecNode |
ExecNodeQueryStrategy.getExecNode()
Returns execution node.
|
Constructor and Description |
---|
ExecNodeQueryStrategy(int forStream,
int numStreams,
ExecNode execNode)
CTor.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecNodeAllUnidirectionalOuter |
class |
ExecNodeNoOp |
class |
HistoricalDataExecNode
Execution node for executing a join or outer join against a historical data source,
using an lookup strategy for looking up into cached indexes, and an indexing strategy for indexing poll results
for future lookups.
|
class |
LookupInstructionExecNode
Execution for a set of lookup instructions and for a set of result assemble instructions to perform
joins and construct a complex result.
|
class |
NestedIterationExecNode
Execution node that performs a nested iteration over all child nodes.
|
class |
TableLookupExecNode
Execution node for lookup in a table.
|
class |
TableLookupExecNodeTableLocking
Execution node for lookup in a table.
|
class |
TableOuterLookupExecNode
Execution node for lookup in a table for outer joins.
|
class |
TableOuterLookupExecNodeTableLocking |
Modifier and Type | Method and Description |
---|---|
void |
NestedIterationExecNode.addChildNode(ExecNode childNode)
Add a child node.
|
static String |
ExecNode.print(ExecNode execNode)
Print in readable format the execution strategy.
|
Modifier and Type | Method and Description |
---|---|
ExecNode |
TableOuterLookupNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
TableLookupNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeNoOp.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeAllUnidirectionalOuter.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
abstract ExecNode |
QueryPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks)
Make execution node from this specification.
|
ExecNode |
NestedIterationNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexList,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
LookupInstructionQueryPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
HistoricalDataPlanNode.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |