Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
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.named |
Named window classes are in this package
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.variable |
Variable service and variable collections
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Modifier and Type | Class and Description |
---|---|
class |
StatementResultServiceImpl
Implements tracking of statement listeners and subscribers for a given statement
such as to efficiently dispatch in situations where 0, 1 or more listeners
are attached and/or 0 or 1 subscriber (such as iteration-only statement).
|
Modifier and Type | Field and Description |
---|---|
protected StatementResultService |
UpdateDispatchViewBase.statementResultService
Handles result delivery
|
Modifier and Type | Method and Description |
---|---|
StatementResultService |
UpdateDispatchViewBase.getStatementResultService() |
StatementResultService |
StatementContext.getStatementResultService()
Returns the service that handles awareness of listeners/subscriptions for a statement customizing output produced
|
StatementResultService |
InternalRoutePreprocessView.getStatementResultService() |
Constructor and Description |
---|
InternalRoutePreprocessView(EventType eventType,
StatementResultService statementResultService)
Ctor.
|
StatementContext(StatementContextEngineServices stmtEngineServices,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EPStatementHandle epStatementHandle,
ViewResolutionService viewResultionService,
PatternObjectResolutionService patternResolutionService,
StatementExtensionSvcContext statementExtensionSvcContext,
StatementStopService statementStopService,
PatternContextFactory patternContextFactory,
FilterService filterService,
StatementResultService statementResultService,
InternalEventRouteDest internalEventEngineRouteDest,
Annotation[] annotations,
StatementAIResourceRegistry statementAgentInstanceRegistry,
StatementAgentInstanceLock defaultAgentInstanceLock,
ContextDescriptor contextDescriptor,
PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
boolean statelessSelect,
ContextControllerFactoryService contextControllerFactoryService,
AgentInstanceScriptContext defaultAgentInstanceScriptContext,
AggregationServiceFactoryService aggregationServiceFactoryService,
boolean writesToTables,
Object statementUserObject,
StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry,
int priority) |
UpdateDispatchViewBase(StatementResultService statementResultServiceImpl,
DispatchService dispatchService)
Ctor.
|
UpdateDispatchViewBlockingSpin(StatementResultService statementResultService,
DispatchService dispatchService,
long msecTimeout,
TimeSourceService timeSourceService)
Ctor.
|
UpdateDispatchViewBlockingWait(StatementResultService statementResultServiceImpl,
DispatchService dispatchService,
long msecTimeout)
Ctor.
|
UpdateDispatchViewNonBlocking(StatementResultService statementResultServiceImpl,
DispatchService dispatchService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(Collection<Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoEventType,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
TableService tableService,
TimeProvider timeProvider,
String engineURI,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowMgmtService namedWindowMgmtService,
IntoTableSpec intoTableClause,
com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo,
StatementExtensionSvcContext statementExtensionSvcContext) |
Constructor and Description |
---|
SelectExprResultProcessor(StatementResultService statementResultService,
SelectExprProcessor syntheticProcessor,
BindProcessor bindProcessor)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected StatementResultService |
NamedWindowTailView.statementResultService |
Modifier and Type | Method and Description |
---|---|
StatementResultService |
NamedWindowTailView.getStatementResultService() |
StatementResultService |
NamedWindowOnUpdateViewFactory.getStatementResultService() |
StatementResultService |
NamedWindowOnSelectViewFactory.getStatementResultService() |
StatementResultService |
NamedWindowOnMergeViewFactory.getStatementResultService() |
StatementResultService |
NamedWindowOnDeleteViewFactory.getStatementResultService() |
Modifier and Type | Method and Description |
---|---|
NamedWindowProcessor |
NamedWindowMgmtServiceImpl.addProcessor(String name,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow,
NamedWindowDispatchService namedWindowDispatchService) |
NamedWindowProcessor |
NamedWindowMgmtService.addProcessor(String name,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow,
NamedWindowDispatchService namedWindowDispatchService) |
NamedWindowProcessor |
NamedWindowDispatchServiceImpl.createProcessor(String name,
NamedWindowMgmtServiceImpl namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean enableQueryPlanLog,
MetricReportingService metricReportingService,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow) |
NamedWindowProcessor |
NamedWindowDispatchService.createProcessor(String name,
NamedWindowMgmtServiceImpl namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean enableQueryPlanLog,
MetricReportingService metricReportingService,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow) |
NamedWindowTailView |
NamedWindowDispatchServiceImpl.createTailView(EventType eventType,
NamedWindowMgmtService namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
boolean prioritized,
boolean parentBatchWindow,
String contextName,
TimeSourceService timeSourceService,
ConfigurationEngineDefaults.Threading threadingConfig) |
NamedWindowTailView |
NamedWindowDispatchService.createTailView(EventType eventType,
NamedWindowMgmtService namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
boolean prioritized,
boolean parentBatchWindow,
String contextName,
TimeSourceService timeSourceService,
ConfigurationEngineDefaults.Threading threadingConfig) |
Constructor and Description |
---|
NamedWindowOnDeleteViewFactory(EventType namedWindowEventType,
StatementResultService statementResultService) |
NamedWindowOnMergeViewFactory(EventType namedWindowEventType,
NamedWindowOnMergeHelper namedWindowOnMergeHelper,
StatementResultService statementResultService,
StatementMetricHandle createNamedWindowMetricHandle,
MetricReportingService metricReportingService) |
NamedWindowOnSelectViewFactory(EventType namedWindowEventType,
InternalEventRouter internalEventRouter,
boolean addToFront,
EPStatementHandle statementHandle,
EventBeanReader eventBeanReader,
boolean distinct,
StatementResultService statementResultService,
InternalEventRouteDest internalEventRouteDest,
boolean deleteAndSelect,
StreamSelector optionalStreamSelector,
String optionalInsertIntoTableName) |
NamedWindowOnUpdateViewFactory(EventType namedWindowEventType,
StatementResultService statementResultService,
EventBeanUpdateHelper updateHelper) |
NamedWindowProcessor(String namedWindowName,
NamedWindowMgmtService namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean enableQueryPlanLog,
MetricReportingService metricReportingService,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow) |
NamedWindowTailView(EventType eventType,
NamedWindowMgmtService namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
boolean prioritized,
boolean parentBatchWindow,
TimeSourceService timeSourceService,
ConfigurationEngineDefaults.Threading threadingConfig) |
Modifier and Type | Method and Description |
---|---|
StatementResultService |
TableOnUpdateViewFactory.getStatementResultService() |
StatementResultService |
TableOnSelectViewFactory.getStatementResultService() |
StatementResultService |
TableOnMergeViewFactory.getStatementResultService() |
StatementResultService |
TableOnDeleteViewFactory.getStatementResultService() |
Constructor and Description |
---|
TableOnDeleteViewFactory(StatementResultService statementResultService,
TableMetadata tableMetadata) |
TableOnMergeViewFactory(TableMetadata tableMetadata,
TableOnMergeHelper onMergeHelper,
StatementResultService statementResultService,
StatementMetricHandle metricsHandle,
MetricReportingServiceSPI metricReportingService) |
TableOnSelectViewFactory(TableMetadata tableMetadata,
InternalEventRouter internalEventRouter,
EPStatementHandle statementHandle,
EventBeanReader eventBeanReader,
boolean distinct,
StatementResultService statementResultService,
InternalEventRouteDest internalEventRouteDest,
boolean deleteAndSelect) |
TableOnUpdateViewFactory(StatementResultService statementResultService,
TableMetadata tableMetadata,
EventBeanUpdateHelper updateHelper,
TableUpdateStrategy tableUpdateStrategy) |
Modifier and Type | Method and Description |
---|---|
StatementResultService |
OnSetVariableViewFactory.getStatementResultService() |
Constructor and Description |
---|
CreateVariableView(int statementId,
EventAdapterService eventAdapterService,
VariableService variableService,
String variableName,
StatementResultService statementResultService,
int agentInstanceId)
Ctor.
|
OnSetVariableViewFactory(int statementId,
OnTriggerSetDesc desc,
EventAdapterService eventAdapterService,
VariableService variableService,
StatementResultService statementResultService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
StatementResultService |
OutputProcessViewDirectFactory.getStatementResultService() |