Package | Description |
---|---|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.fafquery |
Fire-and-forget query execution planning.
|
com.espertech.esper.epl.index.quadtree |
Quad-tree indexes
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
Modifier and Type | Method and Description |
---|---|
VirtualDWView |
FireAndForgetInstanceTable.getVirtualDataWindow() |
VirtualDWView |
FireAndForgetInstanceNamedWindow.getVirtualDataWindow() |
abstract VirtualDWView |
FireAndForgetInstance.getVirtualDataWindow() |
Modifier and Type | Method and Description |
---|---|
static Collection<EventBean> |
FireAndForgetQueryExec.snapshot(QueryGraph queryGraph,
Annotation[] annotations,
VirtualDWView virtualDataWindow,
EventTableIndexRepository indexRepository,
boolean queryPlanLogging,
org.slf4j.Logger queryPlanLogDestination,
String objectName,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategy |
SubordTableLookupStrategyFactoryQuadTree.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
Modifier and Type | Method and Description |
---|---|
LookupInstructionExec |
LookupInstructionPlan.makeExec(String statementName,
int statementId,
Annotation[] annotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
HistoricalStreamIndexList[] historicalStreamIndexLists,
VirtualDWView[] viewExternal)
Constructs the executable from the plan.
|
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) |
JoinExecTableLookupStrategy |
TableLookupPlan.makeStrategy(String statementName,
int statementId,
Annotation[] accessedByStmtAnnotations,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] eventTypes,
VirtualDWView[] viewExternals) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategy |
SubordTableLookupStrategyFactoryVDW.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordTableLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordSortedTableLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordInKeywordSingleTableLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordInKeywordMultiTableLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategySinglePropFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategySingleExprFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategySingleCoercingFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategyPropFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategyExprFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordIndexedTableLookupStrategyCoercingFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordFullTableScanLookupStrategy |
SubordFullTableScanLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordTableLookupStrategy |
SubordCompositeTableLookupStrategyFactory.makeStrategy(EventTable[] eventTable,
VirtualDWView vdw) |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryIndexedUnfiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow) |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryIndexedFiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow) |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryAllUnfiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow) |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryAllFiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow) |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactory.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow) |
Modifier and Type | Method and Description |
---|---|
VirtualDWView |
NamedWindowRootViewInstance.getVirtualDataWindow() |
Modifier and Type | Class and Description |
---|---|
class |
VirtualDWViewImpl |
Modifier and Type | Method and Description |
---|---|
VirtualDWView |
VirtualDWViewProviderForAgentInstance.getView(AgentInstanceContext agentInstanceContext) |