Modifier and Type | Method and Description |
---|---|
StatementContext |
VirtualDataWindowContext.getStatementContext()
Returns the statement context which holds statement information (name, expression, id) and statement-level services.
|
Modifier and Type | Method and Description |
---|---|
void |
ViewableActivatorNamedWindow.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactory.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactory.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactory.statementDestroy(StatementContext statementContext) |
default void |
StatementAgentInstanceFactory.statementDestroyPreconditions(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateClass.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateClass.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateClass.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateContext.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateContext.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
StatementAgentInstanceFactoryCreateContext.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateContext.statementDestroy(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateContext.statementDestroyPreconditions(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
DataflowDesc.getStatementContext() |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateDataflow.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateDataflow.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
DataflowDesc.setStatementContext(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateDataflow.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateDataflow.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateExpression.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateExpression.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateExpression.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateIndex.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateIndex.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateIndex.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateSchema.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateSchema.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateSchema.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateTable.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateTable.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
StatementAgentInstanceFactoryCreateTable.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateTable.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateVariable.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateVariable.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
StatementAgentInstanceFactoryCreateVariable.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateVariable.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryCreateNW.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryCreateNW.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
StatementAgentInstanceFactoryCreateNW.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryCreateNW.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
StatementAgentInstanceFactoryOnTriggerBase.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryOnTriggerBase.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerSet.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerSplitStream.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryOnTriggerSplitStream.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
static StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerUtil.obtainAgentInstanceLock(StatementAgentInstanceFactoryOnTriggerInfraBase base,
StatementContext statementContext,
int agentInstanceId) |
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerInfraUpdate.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerInfraSelect.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerInfraMerge.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
StatementAgentInstanceLock |
StatementAgentInstanceFactoryOnTriggerInfraDelete.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryOnTriggerInfraBase.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
protected InfraOnExprBaseViewFactory |
StatementAgentInstanceFactoryOnTriggerInfraUpdate.setupFactory(EventType infraEventType,
NamedWindow namedWindow,
Table table,
StatementContext statementContext) |
protected InfraOnExprBaseViewFactory |
StatementAgentInstanceFactoryOnTriggerInfraSelect.setupFactory(EventType infraEventType,
NamedWindow namedWindow,
Table table,
StatementContext statementContext) |
protected InfraOnExprBaseViewFactory |
StatementAgentInstanceFactoryOnTriggerInfraMerge.setupFactory(EventType infraEventType,
NamedWindow namedWindow,
Table table,
StatementContext statementContext) |
protected InfraOnExprBaseViewFactory |
StatementAgentInstanceFactoryOnTriggerInfraDelete.setupFactory(EventType infraEventType,
NamedWindow namedWindow,
Table table,
StatementContext statementContext) |
protected abstract InfraOnExprBaseViewFactory |
StatementAgentInstanceFactoryOnTriggerInfraBase.setupFactory(EventType infraEventType,
NamedWindow namedWindow,
Table table,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactorySelect.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactorySelect.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactorySelect.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementAgentInstanceLock |
StatementAgentInstanceFactoryUpdate.obtainAgentInstanceLock(StatementContext statementContext,
int agentInstanceId) |
void |
StatementAgentInstanceFactoryUpdate.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
StatementAgentInstanceFactoryUpdate.statementCreate(StatementContext statementContext) |
void |
StatementAgentInstanceFactoryUpdate.statementDestroy(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerDetailKeyed.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
ContextManagerResident.getStatementContextCreate() |
Modifier and Type | Method and Description |
---|---|
static MappedEventBean |
ContextManagerUtil.buildContextProperties(int agentInstanceId,
Object[] allPartitionKeys,
ContextDefinition contextDefinition,
StatementContext statementContextCreate) |
static AgentInstance |
ContextManagerUtil.getAgentInstance(StatementContext statementContext,
int agentInstanceId) |
ContextAgentInstanceInfo |
ContextManagerResident.getContextAgentInstanceInfo(StatementContext statementContextOfStatement,
int agentInstanceId) |
ContextAgentInstanceInfo |
ContextManager.getContextAgentInstanceInfo(StatementContext statementContextOfStatement,
int agentInstanceId) |
ContextPartitionIdService |
ContextServiceFactoryDefault.getContextPartitionIdService(StatementContext statementContextCreateContext,
DataInputOutputSerde[] bindings,
StateMgmtSetting stateMgmtSettings) |
ContextPartitionIdService |
ContextServiceFactory.getContextPartitionIdService(StatementContext statementContextCreateContext,
DataInputOutputSerde[] bindings,
StateMgmtSetting stateMgmtSettings) |
void |
ContextManagerResident.setStatementContext(StatementContext statementContext) |
void |
ContextManager.setStatementContext(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
int |
ContextManagerResident.countStatements(Function<StatementContext,Boolean> filter) |
int |
ContextManager.countStatements(Function<StatementContext,Boolean> filter) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
StatementLightweight.getStatementContext() |
Modifier and Type | Method and Description |
---|---|
void |
StatementReadyCallback.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Constructor and Description |
---|
StatementLightweight(StatementProvider statementProvider,
StatementInformationalsRuntime statementInformationals,
StatementResultService statementResultService,
StatementContext statementContext) |
Modifier and Type | Field and Description |
---|---|
protected StatementContext |
ExprEvaluatorContextStatement.statementContext |
Modifier and Type | Method and Description |
---|---|
StatementContext |
StatementContextCPPair.getOptionalStatementContext() |
StatementContext |
InternalEventRouterEntry.getStatementContext() |
StatementContext |
AgentInstanceContext.getStatementContext() |
StatementContext |
StatementContextResolver.getStatementContextById(int statementId) |
Modifier and Type | Method and Description |
---|---|
void |
InternalEventRouterImpl.addPreprocessing(InternalEventRouterDesc internalEventRouterDesc,
InternalRoutePreprocessView outputView,
StatementContext statementContext,
boolean hasSubselect) |
void |
InternalEventRouter.addPreprocessing(InternalEventRouterDesc internalEventRouterDesc,
InternalRoutePreprocessView outputView,
StatementContext statementContext,
boolean hasSubselect) |
int |
StatementCPCacheService.clear(StatementContext statementContext) |
void |
StatementDestroyCallback.destroy(StatementDestroyServices destroyServices,
StatementContext statementContext) |
StatementResourceHolder |
StatementCPCacheService.makeOrGetEntryCanNull(int agentInstanceId,
StatementContext statementContext) |
void |
InternalEventRouterImpl.movePreprocessing(StatementContext statementContext,
InternalEventRouter internalEventRouter) |
static StatementAgentInstanceLock |
AgentInstanceUtil.newLock(StatementContext statementContext) |
void |
StatementFinalizeCallback.statementDestroyed(StatementContext context) |
Constructor and Description |
---|
AgentInstanceContext(StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
AgentInstanceFilterProxy agentInstanceFilterProxy,
MappedEventBean contextProperties,
AuditProvider auditProvider,
InstrumentationCommon instrumentationProvider) |
ExprEvaluatorContextStatement(StatementContext statementContext,
boolean allowTableAccess) |
InternalEventRouterEntry(int priority,
boolean drop,
ExprEvaluator optionalWhereClause,
ExprEvaluator[] assignments,
EventBeanWriter writer,
TypeWidener[] wideners,
InternalEventRouterWriter[] specialPropWriters,
InternalRoutePreprocessView outputView,
StatementContext statementContext,
boolean hasSubselect)
Ctor.
|
StatementContextCPPair(int statementId,
int agentInstanceId,
StatementContext optionalStatementContext) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
DataFlowOpFactoryInitializeContext.getStatementContext() |
Constructor and Description |
---|
DataFlowOpFactoryInitializeContext(String dataFlowName,
int operatorNumber,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
FireAndForgetProcessorTable.getStatementContext() |
StatementContext |
FireAndForgetProcessorNamedWindow.getStatementContext() |
abstract StatementContext |
FireAndForgetProcessor.getStatementContext() |
Modifier and Type | Method and Description |
---|---|
void |
HistoricalEventViewableDatabaseFactory.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
void |
HistoricalEventViewableMethodFactory.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
void |
MethodTargetStrategyVariableFactory.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
MethodTargetStrategyStaticMethod.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
void |
MethodTargetStrategyScript.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
void |
NamedWindowConsumerManagementServiceImpl.addConsumer(String namedWindowDeploymentId,
String namedWindowName,
int namedWindowConsumerId,
StatementContext statementContext,
boolean subquery) |
void |
NamedWindowConsumerManagementService.addConsumer(String namedWindowDeploymentId,
String namedWindowName,
int namedWindowConsumerId,
StatementContext statementContext,
boolean subquery) |
void |
NamedWindowConsumerManagementServiceImpl.destroyConsumer(String namedWindowDeploymentId,
String namedWindowName,
StatementContext statementContext) |
void |
NamedWindowConsumerManagementService.destroyConsumer(String namedWindowDeploymentId,
String namedWindowName,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
NamedWindowImpl.getStatementContext() |
StatementContext |
NamedWindow.getStatementContext() |
Modifier and Type | Method and Description |
---|---|
void |
NamedWindowImpl.setStatementContext(StatementContext statementContext) |
void |
NamedWindow.setStatementContext(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
InfraOnMergeActionUpd.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Constructor and Description |
---|
InfraOnUpdateViewFactory(EventType infraEventType,
EventBeanUpdateHelperWCopy updateHelperNamedWindow,
EventBeanUpdateHelperNoCopy updateHelperTable,
Table table,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
OutputConditionExpressionFactory.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
static void |
OutputStrategyUtil.indicateEarlyReturn(StatementContext statementContext,
UniformPair<EventBean[]> newOldEvents)
Indicate statement result.
|
Modifier and Type | Method and Description |
---|---|
boolean |
OutputProcessViewBaseWAfter.checkAfterCondition(EventBean[] newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewBaseWAfter.checkAfterCondition(Set<MultiKeyArrayOfKeys<EventBean>> newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewBaseWAfter.checkAfterCondition(UniformPair<EventBean[]> newOldEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterStateNone.checkUpdateAfterCondition(EventBean[] newEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateImpl.checkUpdateAfterCondition(EventBean[] newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterState.checkUpdateAfterCondition(EventBean[] newEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateNone.checkUpdateAfterCondition(Set<MultiKeyArrayOfKeys<EventBean>> newEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateImpl.checkUpdateAfterCondition(Set<MultiKeyArrayOfKeys<EventBean>> newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterState.checkUpdateAfterCondition(Set<MultiKeyArrayOfKeys<EventBean>> newEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateNone.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateImpl.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterState.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
PatternAgentInstanceContext.getStatementContext() |
Modifier and Type | Method and Description |
---|---|
void |
EvalFollowedByFactoryNode.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Method and Description |
---|---|
static AgentInstanceScriptContext |
AgentInstanceScriptContext.from(StatementContext statementContext) |
Constructor and Description |
---|
AgentInstanceScriptContext(StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
SubSelectFactory.ready(StatementContext statementContext,
ModuleIncidentals moduleIncidentals,
boolean recovery) |
Modifier and Type | Field and Description |
---|---|
protected StatementContext |
TableBase.statementContextCreateTable |
Modifier and Type | Method and Description |
---|---|
StatementContext |
TableBase.getStatementContextCreateTable() |
StatementContext |
Table.getStatementContextCreateTable() |
Modifier and Type | Method and Description |
---|---|
TableSerdes |
TableManagementServiceImpl.getTableSerdes(Table table,
DataInputOutputSerde aggregationSerde,
StatementContext statementContext) |
void |
TableBase.setStatementContextCreateTable(StatementContext statementContextCreateTable) |
void |
Table.setStatementContextCreateTable(StatementContext statementContextCreateTable) |
Modifier and Type | Method and Description |
---|---|
void |
ExceptionHandlingService.handleCondition(BaseCondition condition,
StatementContext statement) |
Modifier and Type | Method and Description |
---|---|
StatementContext |
AgentInstanceViewFactoryChainContext.getStatementContext() |
Copyright © 2005–2021. All rights reserved.