Package | Description |
---|---|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.table.merge |
Table on-merge handlers.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.table.upd |
Table update strategies.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
Constructor and Description |
---|
FireAndForgetInstanceTable(TableStateInstance instance) |
Modifier and Type | Method and Description |
---|---|
TableStateInstance |
AggregationServiceTable.getTableState() |
Constructor and Description |
---|
AggregationServiceTable(TableStateInstance tableState) |
Constructor and Description |
---|
NamedWindowOnSelectView(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance rootView,
ExprEvaluatorContext exprEvaluatorContext,
NamedWindowOnSelectViewFactory parent,
ResultSetProcessor resultSetProcessor,
boolean audit,
boolean isDelete,
TableStateInstance tableStateInstanceInsertInto) |
Modifier and Type | Method and Description |
---|---|
void |
TableOnMergeMatch.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance stateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext context) |
void |
TableOnMergeActionUpd.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableOnMergeActionIns.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableOnMergeActionDel.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
TableOnMergeAction.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Class and Description |
---|---|
class |
TableStateInstanceGroupedImpl |
class |
TableStateInstanceUngroupedImpl |
Modifier and Type | Method and Description |
---|---|
TableStateInstance |
TableMetadata.getState(int agentInstanceId) |
TableStateInstance |
TableServiceImpl.getState(String name,
int agentInstanceId) |
TableStateInstance |
TableService.getState(String name,
int agentInstanceId) |
TableStateInstance |
TableStateFactory.makeTableState(AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
TableStateViewableInternal(TableMetadata tableMetadata,
TableStateInstance tableStateInstance,
ExprEvaluator[] optionalTableFilters) |
TableStateViewablePublic(TableMetadata tableMetadata,
TableStateInstance tableStateInstance) |
Modifier and Type | Field and Description |
---|---|
protected TableStateInstance |
TableOnViewBase.tableStateInstance |
Modifier and Type | Method and Description |
---|---|
void |
TableUpdateStrategyWUniqueConstraint.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategyNonIndex.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategyIndexNonUnique.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategy.updateTable(Collection<EventBean> events,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
OutputStrategyPostProcess(OutputStrategyPostProcessFactory parent,
AgentInstanceContext agentInstanceContext,
TableStateInstance tableStateInstance) |