Package | Description |
---|---|
com.espertech.esper.epl.core.eval |
Select expression evaluators.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.event.vaevent |
Value added events are revision events and variant events.
|
Modifier and Type | Field and Description |
---|---|
protected ValueAddEventProcessor |
NamedWindowTailView.revisionProcessor |
Modifier and Type | Method and Description |
---|---|
ValueAddEventProcessor |
NamedWindowTailView.getRevisionProcessor() |
ValueAddEventProcessor |
NamedWindowRootView.getRevisionProcessor() |
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 |
---|
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) |
NamedWindowRootView(ValueAddEventProcessor revisionProcessor,
boolean queryPlanLogging,
MetricReportingService metricReportingService,
EventType eventType,
boolean childBatching,
boolean isEnableIndexShare,
Set<String> optionalUniqueKeyProps) |
NamedWindowTailView(EventType eventType,
NamedWindowMgmtService namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
boolean prioritized,
boolean parentBatchWindow,
TimeSourceService timeSourceService,
ConfigurationEngineDefaults.Threading threadingConfig) |
Modifier and Type | Class and Description |
---|---|
class |
VAERevisionProcessorBase
Base revision processor.
|
class |
VAERevisionProcessorDeclared
Provides overlay strategy for property group-based versioning.
|
class |
VAERevisionProcessorMerge
Provides a set of merge-strategies for merging individual properties (rather then overlaying groups).
|
class |
VAEVariantProcessor
Represents a variant event stream, allowing events of disparate event types to be treated polymophically.
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,ValueAddEventProcessor> |
ValueAddEventServiceImpl.processorsByNamedWindow
Map of named window name and processor.
|
protected Map<String,ValueAddEventProcessor> |
ValueAddEventServiceImpl.variantProcessors
Map of revision event stream and variant stream processor.
|
Modifier and Type | Method and Description |
---|---|
ValueAddEventProcessor |
ValueAddEventServiceImpl.getValueAddProcessor(String name) |
ValueAddEventProcessor |
ValueAddEventService.getValueAddProcessor(String name)
Gets a value-added event processor.
|