Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
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.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.view.internal |
Internal management views for buffering view results and providing these to joins.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalEventRouterImpl
Routing implementation that allows to pre-process events.
|
Modifier and Type | Field and Description |
---|---|
protected InternalEventRouter |
EPRuntimeImpl.internalEventRouter |
Modifier and Type | Method and Description |
---|---|
void |
InternalEventRouteDest.setInternalEventRouter(InternalEventRouter internalEventRouter) |
void |
EPRuntimeIsolatedImpl.setInternalEventRouter(InternalEventRouter internalEventRouter) |
void |
EPRuntimeImpl.setInternalEventRouter(InternalEventRouter internalEventRouter)
Sets the route for events to use
|
Modifier and Type | Method and Description |
---|---|
InternalEventRouter |
NamedWindowOnSelectViewFactory.getInternalEventRouter() |
Modifier and Type | Method and Description |
---|---|
static NamedWindowOnExprFactory |
NamedWindowOnExprFactoryFactory.make(EventType namedWindowEventType,
String namedWindowName,
String namedWindowAlias,
OnTriggerDesc onTriggerDesc,
EventType filterEventType,
String filterStreamName,
boolean addToFront,
InternalEventRouter internalEventRouter,
EventType outputEventType,
StatementContext statementContext,
StatementMetricHandle createNamedWindowMetricsHandle,
boolean isDistinct,
StreamSelector optionalStreamSelector,
String optionalInsertIntoTableName) |
Constructor and Description |
---|
NamedWindowOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
String insertIntoTableName,
TableService tableService,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit) |
NamedWindowOnMergeHelper(StatementContext statementContext,
OnTriggerMergeDesc onTriggerDesc,
EventType triggeringEventType,
String triggeringStreamName,
InternalEventRouter internalEventRouter,
String namedWindowName,
EventTypeSPI namedWindowType) |
NamedWindowOnSelectViewFactory(EventType namedWindowEventType,
InternalEventRouter internalEventRouter,
boolean addToFront,
EPStatementHandle statementHandle,
EventBeanReader eventBeanReader,
boolean distinct,
StatementResultService statementResultService,
InternalEventRouteDest internalEventRouteDest,
boolean deleteAndSelect,
StreamSelector optionalStreamSelector,
String optionalInsertIntoTableName) |
Constructor and Description |
---|
TableOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit,
TableStateRowFactory tableStateRowFactory) |
TableOnMergeHelper(StatementContext statementContext,
OnTriggerMergeDesc onTriggerDesc,
EventType triggeringEventType,
String triggeringStreamName,
InternalEventRouter internalEventRouter,
TableMetadata tableMetadata) |
Modifier and Type | Method and Description |
---|---|
InternalEventRouter |
TableOnSelectViewFactory.getInternalEventRouter() |
Modifier and Type | Method and Description |
---|---|
static TableOnViewFactory |
TableOnViewFactoryFactory.make(TableMetadata tableMetadata,
OnTriggerDesc onTriggerDesc,
EventType filterEventType,
String filterStreamName,
StatementContext statementContext,
StatementMetricHandle metricsHandle,
boolean isDistinct,
InternalEventRouter internalEventRouter) |
Constructor and Description |
---|
TableOnSelectViewFactory(TableMetadata tableMetadata,
InternalEventRouter internalEventRouter,
EPStatementHandle statementHandle,
EventBeanReader eventBeanReader,
boolean distinct,
StatementResultService statementResultService,
InternalEventRouteDest internalEventRouteDest,
boolean deleteAndSelect) |
Modifier and Type | Method and Description |
---|---|
InternalEventRouter |
OutputStrategyPostProcessFactory.getInternalEventRouter() |
Modifier and Type | Method and Description |
---|---|
static OutputProcessViewFactory |
OutputProcessViewFactoryFactory.make(StatementSpecCompiled statementSpec,
InternalEventRouter internalEventRouter,
StatementContext statementContext,
EventType resultEventType,
OutputProcessViewCallback optionalOutputProcessViewCallback,
TableService tableService,
ResultSetProcessorType resultSetProcessorType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
StatementVariableRef statementVariableRef) |
Constructor and Description |
---|
OutputStrategyPostProcessFactory(boolean route,
SelectClauseStreamSelectorEnum insertIntoStreamSelector,
SelectClauseStreamSelectorEnum selectStreamDirEnum,
InternalEventRouter internalEventRouter,
EPStatementHandle epStatementHandle,
boolean addToFront,
TableService tableService,
String tableName) |
Modifier and Type | Field and Description |
---|---|
protected InternalEventRouter |
RouteResultViewHandlerBase.internalEventRouter |