Package | Description |
---|---|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
Modifier and Type | Class and Description |
---|---|
class |
ContextManagedStatementCreateAggregationVariableDesc |
class |
ContextManagedStatementCreateIndexDesc |
class |
ContextManagedStatementCreateVariableDesc |
class |
ContextManagedStatementCreateWindowDesc |
class |
ContextManagedStatementOnTriggerDesc |
class |
ContextManagedStatementSelectDesc |
Modifier and Type | Method and Description |
---|---|
ContextControllerStatementBase |
ContextControllerStatementDesc.getStatement() |
Modifier and Type | Method and Description |
---|---|
void |
ContextManagerNested.addStatement(ContextControllerStatementBase statement,
boolean isRecoveringResilient) |
void |
ContextManagerImpl.addStatement(ContextControllerStatementBase statement,
boolean isRecoveringResilient) |
void |
ContextManager.addStatement(ContextControllerStatementBase statement,
boolean isRecoveringResilient) |
void |
ContextManagementServiceImpl.addStatement(String contextName,
ContextControllerStatementBase statement,
boolean isRecoveringResilient) |
void |
ContextManagementService.addStatement(String contextName,
ContextControllerStatementBase statement,
boolean isRecoveringResilient) |
ContextControllerStatementCtxCache |
ContextControllerPartitionedFactoryBase.validateStatement(ContextControllerStatementBase statement) |
ContextControllerStatementCtxCache |
ContextControllerInitTermFactoryBase.validateStatement(ContextControllerStatementBase statement) |
ContextControllerStatementCtxCache |
ContextControllerHashFactoryBase.validateStatement(ContextControllerStatementBase statement) |
ContextControllerStatementCtxCache |
ContextControllerFactory.validateStatement(ContextControllerStatementBase statement) |
ContextControllerStatementCtxCache |
ContextControllerCategoryFactoryBase.validateStatement(ContextControllerStatementBase statement) |
protected static void |
ContextControllerPartitionedUtil.validateStatementForContext(String contextName,
ContextControllerStatementBase statement,
StatementSpecCompiledAnalyzerResult streamAnalysis,
Collection<EventType> itemEventTypes,
NamedWindowMgmtService namedWindowMgmtService) |
Constructor and Description |
---|
ContextControllerStatementDesc(ContextControllerStatementBase statement,
ContextControllerStatementCtxCache[] caches) |
Modifier and Type | Method and Description |
---|---|
static StatementAgentInstanceFactoryResult |
StatementAgentInstanceUtil.start(EPServicesContext servicesContext,
ContextControllerStatementBase statement,
boolean isSingleInstanceContext,
int agentInstanceId,
MappedEventBean agentInstanceProperties,
AgentInstanceFilterProxy agentInstanceFilterProxy,
boolean isRecoveringResilient) |