Package | Description |
---|---|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
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.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.named |
Named window classes are in this package
|
com.espertech.esper.epl.subquery |
Subquery helper classes are found here.
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.window |
Window views are in this package
|
Modifier and Type | Class and Description |
---|---|
class |
ViewableActivatorFilterProxyStopCallback |
class |
ViewableActivatorStreamReuseView |
Modifier and Type | Method and Description |
---|---|
StopCallback |
ViewableActivationResult.getStopCallback() |
Constructor and Description |
---|
ViewableActivationResult(Viewable viewable,
StopCallback stopCallback,
StatementAgentInstanceLock optionalLock,
EvalRootState optionalPatternRoot,
EvalRootMatchRemover optEvalRootMatchRemover,
boolean suppressSameEventMatches,
boolean discardPartialsOnMatch,
ViewableActivationResultExtension viewableActivationResultExtension) |
Modifier and Type | Method and Description |
---|---|
StopCallback |
StatementAgentInstanceFactoryResult.getStopCallback() |
Modifier and Type | Method and Description |
---|---|
void |
StatementAgentInstanceFactoryResult.setStopCallback(StopCallback stopCallback) |
Modifier and Type | Method and Description |
---|---|
protected static void |
StatementAgentInstanceFactorySelect.addViewStopCallback(List<StopCallback> stopCallbacks,
List<View> topViews) |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerTable.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbacks,
boolean isRecoveringReslient) |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSplit.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbacks,
boolean isRecoveringReslient) |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSetVariable.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbacks,
boolean isRecoveringReslient) |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerNamedWindow.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbacks,
boolean isRecoveringReslient) |
abstract StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerBase.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbacks,
boolean isRecoveringReslient) |
Constructor and Description |
---|
StatementAgentInstanceFactoryOnTriggerNamedWindow(StatementContext statementContext,
StatementSpecCompiled statementSpec,
EPServicesContext services,
ViewableActivator activator,
SubSelectStrategyCollection subSelectStrategyCollection,
ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
ExprNode validatedJoin,
ResultSetProcessorFactoryDesc outputResultSetProcessorPrototype,
NamedWindowOnExprFactory onExprFactory,
OutputProcessViewFactory outputProcessViewFactory,
EventType activatorResultEventType,
NamedWindowProcessor processor,
List<StopCallback> stopCallbacks) |
Modifier and Type | Method and Description |
---|---|
StopCallback |
AgentInstance.getStopCallback() |
Constructor and Description |
---|
AgentInstance(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView) |
Modifier and Type | Interface and Description |
---|---|
interface |
AIRegistryAggregation |
Modifier and Type | Class and Description |
---|---|
class |
AIRegistryAggregationMap |
class |
AIRegistryAggregationMultiPerm |
class |
AIRegistryAggregationSingle |
Modifier and Type | Method and Description |
---|---|
SubSelectStrategyRealization |
SubSelectStrategyFactoryLocalViewPreloaded.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactoryIndexShare.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactory.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
Modifier and Type | Method and Description |
---|---|
static StopCallback |
StatementAgentInstanceUtil.getStopCallback(List<StopCallback> stopCallbacks,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
Collection<StopCallback> |
AgentInstanceContext.getTerminationCallbackRO() |
Collection<StopCallback> |
AgentInstanceViewFactoryChainContext.getTerminationCallbacksRO() |
Modifier and Type | Method and Description |
---|---|
void |
AgentInstanceViewFactoryChainContext.addTerminationCallback(StopCallback callback) |
void |
AgentInstanceContext.addTerminationCallback(StopCallback callback) |
void |
AgentInstanceViewFactoryChainContext.removeTerminationCallback(StopCallback callback) |
void |
AgentInstanceContext.removeTerminationCallback(StopCallback callback) |
static void |
StatementAgentInstanceUtil.stop(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired,
boolean removedStatementResources) |
static void |
StatementAgentInstanceUtil.stopSafe(Collection<StopCallback> terminationCallbacks,
StopCallback[] stopCallbacks,
StatementContext statementContext) |
static void |
StatementAgentInstanceUtil.stopSafe(StopCallback[] stopMethods,
StatementContext statementContext) |
static void |
StatementAgentInstanceUtil.stopSafe(StopCallback stopMethod,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
static StopCallback |
StatementAgentInstanceUtil.getStopCallback(List<StopCallback> stopCallbacks,
AgentInstanceContext agentInstanceContext) |
static void |
StatementAgentInstanceUtil.stopSafe(Collection<StopCallback> terminationCallbacks,
StopCallback[] stopCallbacks,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StopCallback |
EPStatementFactoryDefault.makeStopMethod(StatementAgentInstanceFactoryResult startResult) |
StopCallback |
EPStatementFactory.makeStopMethod(StatementAgentInstanceFactoryResult startResult) |
Modifier and Type | Method and Description |
---|---|
void |
StatementExtensionSvcContext.contributeStopCallback(StatementAgentInstanceFactoryResult selectResult,
List<StopCallback> stopCallbacks) |
Modifier and Type | Method and Description |
---|---|
static Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
boolean isRecoveringResilient) |
Constructor and Description |
---|
EPStatementStopMethodImpl(StatementContext statementContext,
List<StopCallback> stopCallbacks) |
Modifier and Type | Interface and Description |
---|---|
interface |
AggregationService
Service for maintaining aggregation state.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationServiceBase
All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.)
and aggregation state factories to make new aggregation states.
|
class |
AggregationServiceBaseGrouped
All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.)
and aggregation state factories to make new aggregation states.
|
class |
AggregationServiceBaseUngrouped
All aggregation services require evaluation nodes which supply the value to be aggregated (summed, averaged, etc.)
and aggregation state factories to make new aggregation states.
|
class |
AggregationServiceNull
A null object implementation of the AggregationService
interface.
|
class |
AggregationServiceTable |
class |
AggSvcGroupAllAccessOnlyImpl
Aggregation service for use when only first/last/window aggregation functions are used an none other.
|
class |
AggSvcGroupAllLocalGroupBy
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupAllMixedAccessImpl
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupAllMixedAccessWTableImpl
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupAllNoAccessImpl
Implementation for handling aggregation without any grouping (no group-by).
|
class |
AggSvcGroupByAccessOnlyImpl
Aggregation service for use when only first/last/window aggregation functions are used an none other.
|
class |
AggSvcGroupByLocalGroupBy
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByMixedAccessImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByNoAccessImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByReclaimAgedImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedNoAccessImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedWAccessImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByRefcountedWAccessRollupImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByWTableBase
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByWTableImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByWTableRollupMultiKeyImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupByWTableRollupSingleKeyImpl
Implementation for handling aggregation with grouping by group-keys.
|
class |
AggSvcGroupLocalGroupByBase
Implementation for handling aggregation with grouping by group-keys.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResultSetProcessor
Processor for result sets coming from 2 sources.
|
Modifier and Type | Class and Description |
---|---|
class |
MethodPollingViewable
Polling-data provider that calls a static method on a class and passed parameters, and wraps the
results as POJO events.
|
class |
ResultSetProcessorAggregateAll
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and not all of the properties in the select clause are under an aggregation function.
|
class |
ResultSetProcessorAggregateGrouped
Result-set processor for the aggregate-grouped case:
there is a group-by and one or more non-aggregation event properties in the select clause are not listed in the group by,
and there are aggregation functions.
|
class |
ResultSetProcessorBaseSimple
Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
|
class |
ResultSetProcessorHandThrough
Result set processor for the hand-through case:
no aggregation functions used in the select clause, and no group-by, no having and ordering.
|
class |
ResultSetProcessorRowForAll
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and all properties in the select clause are under an aggregation function.
|
class |
ResultSetProcessorRowPerGroup
Result set processor for the fully-grouped case:
there is a group-by and all non-aggregation event properties in the select clause are listed in the group by,
and there are aggregation functions.
|
class |
ResultSetProcessorRowPerGroupRollup |
class |
ResultSetProcessorRowPerGroupRollupUnbound |
class |
ResultSetProcessorRowPerGroupUnbound |
class |
ResultSetProcessorSimple
Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
|
Modifier and Type | Class and Description |
---|---|
class |
DatabasePollingViewable
Implements a poller viewable that uses a polling strategy, a cache and
some input parameters extracted from event streams to perform the polling.
|
Modifier and Type | Class and Description |
---|---|
class |
NamedWindowConsumerView
Represents a consumer of a named window that selects from a named window via a from-clause.
|
Modifier and Type | Class and Description |
---|---|
class |
SubqueryStopCallback
Implements a stop callback for use with subqueries to clear their indexes
when a statement is stopped.
|
Modifier and Type | Class and Description |
---|---|
class |
TableOnDeleteView
View for the on-delete statement that handles removing events from a named window.
|
class |
TableOnMergeView |
class |
TableOnSelectView |
class |
TableOnUpdateView |
class |
TableOnViewBase |
Modifier and Type | Class and Description |
---|---|
class |
OutputConditionExpression
Output condition for output rate limiting that handles when-then expressions for controlling output.
|
class |
OutputConditionTime
Output condition that is satisfied at the end
of every time interval of a given length.
|
class |
OutputProcessViewBase |
class |
OutputProcessViewBaseCallback
Factory for output processing views.
|
class |
OutputProcessViewBaseWAfter |
class |
OutputProcessViewConditionDefault
A view that prepares output events, batching incoming
events and invoking the result set processor as necessary.
|
class |
OutputProcessViewConditionDefaultPostProcess
A view that prepares output events, batching incoming
events and invoking the result set processor as necessary.
|
class |
OutputProcessViewConditionFirst
Handles output rate limiting for FIRST, only applicable with a having-clause and no group-by clause.
|
class |
OutputProcessViewConditionFirstPostProcess
Handles output rate limiting for FIRST, only applicable with a having-clause and no group-by clause.
|
class |
OutputProcessViewConditionLastAllUnord
Handles output rate limiting for LAST and without order-by.
|
class |
OutputProcessViewConditionLastAllUnordPostProcessAll |
class |
OutputProcessViewConditionSnapshot
A view that handles the "output snapshot" keyword in output rate stabilizing.
|
class |
OutputProcessViewConditionSnapshotPostProcess
A view that handles the "output snapshot" keyword in output rate stabilizing.
|
class |
OutputProcessViewDirect
Output process view that does not enforce any output policies and may simply
hand over events to child views, does not handle distinct.
|
class |
OutputProcessViewDirectDistinctOrAfter
Output process view that does not enforce any output policies and may simply
hand over events to child views, but works with distinct and after-output policies
|
class |
OutputProcessViewDirectDistinctOrAfterPostProcess
Output process view that does not enforce any output policies and may simply
hand over events to child views, but works with distinct and after-output policies
|
class |
OutputProcessViewDirectPostProcess |
Modifier and Type | Interface and Description |
---|---|
interface |
EvalRootState
Interface for a root state node accepting a callback to use to indicate pattern results.
|
interface |
PatternStopCallback
Interface for executing a stop on an active event expression.
|
Modifier and Type | Class and Description |
---|---|
class |
EvalRootStateNode
This class is always the root node in the evaluation state tree representing any activated event expression.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventRowRegexNFAViewService
Service interface for match recognize.
|
Modifier and Type | Class and Description |
---|---|
class |
EventRowRegexNFAView
View for match recognize support.
|
Modifier and Type | Class and Description |
---|---|
class |
StopCallbackNoAction
Stop callback that performs no action.
|
Modifier and Type | Field and Description |
---|---|
static StopCallback |
StopCallbackNoAction.INSTANCE |
static StopCallback |
CollectionUtil.STOP_CALLBACK_NONE |
Modifier and Type | Interface and Description |
---|---|
interface |
HistoricalEventViewable
Interface for views that poll data based on information from other streams.
|
interface |
StoppableView |
Modifier and Type | Class and Description |
---|---|
class |
TimeOrderView
Window retaining timestamped events up to a given number of seconds such that
older events that arrive later are sorted into the window and released in timestamp order.
|
Modifier and Type | Class and Description |
---|---|
class |
IntersectAsymetricView
A view that represents an intersection of multiple data windows.
|
class |
IntersectBatchView
A view that represents an intersection of multiple data windows.
|
class |
IntersectDefaultView
A view that represents an intersection of multiple data windows.
|
class |
UnionAsymetricView
A view that represents a union of multiple data windows wherein at least one is asymetric:
it does not present a insert stream for each insert stream event received.
|
class |
UnionView
A view that represents a union of multiple data windows.
|
Modifier and Type | Class and Description |
---|---|
class |
AddPropertyValueOptionalView
This view simply adds a property to the events posted to it.
|
Modifier and Type | Class and Description |
---|---|
class |
ExpressionBatchView
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
ExpressionViewBase
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
ExpressionWindowView
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
FirstTimeView |
class |
TimeAccumView
A data window view that holds events in a stream and only removes events from a stream (rstream) if
no more events arrive for a given time interval.
|
class |
TimeAccumViewRStream
A data window view that holds events in a stream and only removes events from a stream (rstream) if
no more events arrive for a given time interval, also handling the remove stream
by keeping set-like semantics.
|
class |
TimeBatchView
A data view that aggregates events in a stream and releases them in one batch at every specified time interval.
|
class |
TimeBatchViewRStream
Same as the
TimeBatchView , this view also supports fast-remove from the batch for remove stream events. |
class |
TimeLengthBatchView
A data view that aggregates events in a stream and releases them in one batch if either one of these
conditions is reached, whichever comes first: One, a time interval passes.
|
class |
TimeWindowView
This view is a moving timeWindow extending the specified amount of milliseconds into the past.
|