Package | Description |
---|---|
com.espertech.esper.epl.fafquery |
Fire-and-forget query execution 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.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.event.vaevent |
Value added events are revision events and variant events.
|
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 |
---|---|
static EventTable[] |
SubordinateQueryPlannerUtil.realizeTables(SubordinateQueryIndexDesc[] indexDescriptors,
EventType eventType,
EventTableIndexRepository indexRepository,
Iterable<EventBean> contents,
AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient) |
Modifier and Type | Method and Description |
---|---|
EventTableIndexRepository |
NamedWindowRootViewInstance.getIndexRepository() |
Modifier and Type | Field and Description |
---|---|
protected EventTableIndexRepository |
TableStateInstance.indexRepository |
Modifier and Type | Method and Description |
---|---|
EventTableIndexRepository |
TableStateInstanceGroupedImpl.getIndexRepository() |
EventTableIndexRepository |
TableStateInstanceGrouped.getIndexRepository() |
EventTableIndexRepository |
TableStateInstance.getIndexRepository() |
Modifier and Type | Method and Description |
---|---|
void |
ValueAddEventProcessor.onUpdate(EventBean[] newData,
EventBean[] oldData,
NamedWindowRootViewInstance namedWindowRootView,
EventTableIndexRepository indexRepository)
Upon new events arriving into a named window (new data), and upon events being deleted
via on-delete (old data), update child views of the root view and apply to index repository as required (fast deletion).
|
void |
VAEVariantProcessor.onUpdate(EventBean[] newData,
EventBean[] oldData,
NamedWindowRootViewInstance namedWindowRootView,
EventTableIndexRepository indexRepository) |
void |
VAERevisionProcessorMerge.onUpdate(EventBean[] newData,
EventBean[] oldData,
NamedWindowRootViewInstance namedWindowRootView,
EventTableIndexRepository indexRepository) |
void |
VAERevisionProcessorDeclared.onUpdate(EventBean[] newData,
EventBean[] oldData,
NamedWindowRootViewInstance namedWindowRootView,
EventTableIndexRepository indexRepository) |
void |
ValueAddEventProcessor.removeOldData(EventBean[] oldData,
EventTableIndexRepository indexRepository,
AgentInstanceContext agentInstanceContext)
Called each time a data window posts a remove stream event, to indicate that a data window
remove an event as it expired according to a specified expiration policy.
|
void |
VAEVariantProcessor.removeOldData(EventBean[] oldData,
EventTableIndexRepository indexRepository,
AgentInstanceContext agentInstanceContext) |
void |
VAERevisionProcessorMerge.removeOldData(EventBean[] oldData,
EventTableIndexRepository indexRepository,
AgentInstanceContext agentInstanceContext) |
void |
VAERevisionProcessorDeclared.removeOldData(EventBean[] oldData,
EventTableIndexRepository indexRepository,
AgentInstanceContext agentInstanceContext) |