com.espertech.esper.common.internal.context.util

Class StatementContext

java.lang.Object

com.espertech.esper.common.internal.context.util.StatementContext

All Implemented Interfaces:

ExprEvaluatorContext

public class StatementContext
extends Object
implements ExprEvaluatorContext

Constructor Summary

Constructors

Constructor and Description

StatementContext(ContextRuntimeDescriptor contextRuntimeDescriptor, String deploymentId, int statementId, String statementName, String moduleName, StatementInformationalsRuntime statementInformationals, Object userObjectRuntime, StatementContextRuntimeServices statementContextRuntimeServices, EPStatementHandle epStatementHandle, Map<Integer,FilterSpecActivatable> filterSpecActivatables, PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc, RowRecogStatePoolStmtSvc rowRecogStatePoolStmtSvc, ScheduleBucket scheduleBucket, StatementAIResourceRegistry statementAIResourceRegistry, StatementCPCacheService statementCPCacheService, StatementAIFactoryProvider statementAIFactoryProvider, StatementResultService statementResultService, UpdateDispatchView updateDispatchView)

Method Summary

Modifier and Type	Method and Description
void	addFinalizeCallback(StatementFinalizeCallback callback)
int	getAgentInstanceId()
StatementAgentInstanceLock	getAgentInstanceLock()
AgentInstanceScriptContext	getAllocateAgentInstanceScriptContext()
Annotation[]	getAnnotations()
AuditProvider	getAuditProvider()
ClasspathImportServiceRuntime	getClasspathImportServiceRuntime()
ContextManagementService	getContextManagementService()
String	getContextName()
EventBean	getContextProperties()
ContextRuntimeDescriptor	getContextRuntimeDescriptor()
ContextServiceFactory	getContextServiceFactory()
DatabaseConfigServiceRuntime	getDatabaseConfigService()
DataFlowFilterServiceAdapter	getDataFlowFilterServiceAdapter()
String	getDeploymentId()
StatementDestroyCallback	getDestroyCallback()
EPRuntimeEventProcessWrapped	getEPRuntimeEventProcessWrapped()
EPRenderEventService	getEPRuntimeRenderEvent()
EventServiceSendEventCommon	getEPRuntimeSendEvent()
EPStatementHandle	getEpStatementHandle()
EventBeanService	getEventBeanService()
EventBeanTypedEventFactory	getEventBeanTypedEventFactory()
EventTableIndexService	getEventTableIndexService()
EventTypeAvroHandler	getEventTypeAvroHandler()
PathRegistry<String,EventType>	getEventTypePathRegistry()
EventTypeRepositoryImpl	getEventTypeRepositoryPreconfigured()
EventTypeResolvingBeanFactory	getEventTypeResolvingBeanFactory()
ExceptionHandlingService	getExceptionHandlingService()
ExpressionResultCacheService	getExpressionResultCacheService()
ExpressionResultCacheService	getExpressionResultCacheServiceSharable()
FilterBooleanExpressionFactory	getFilterBooleanExpressionFactory()
FilterService	getFilterService()
FilterSharedBoolExprRepository	getFilterSharedBoolExprRepository()
FilterSharedLookupableRepository	getFilterSharedLookupableRepository()
Map<Integer,FilterSpecActivatable>	getFilterSpecActivatables()
Iterator<StatementFinalizeCallback>	getFinalizeCallbacks()
HistoricalDataCacheFactory	getHistoricalDataCacheFactory()
InstrumentationCommon	getInstrumentationProvider()
InternalEventRouteDest	getInternalEventRouteDest()
InternalEventRouter	getInternalEventRouter()
MetricReportingService	getMetricReportingService()
String	getModuleName()
NamedWindowConsumerManagementService	getNamedWindowConsumerManagementService()
NamedWindowManagementService	getNamedWindowManagementService()
PathRegistry<String,ContextMetaData>	getPathContextRegistry()
PatternSubexpressionPoolStmtSvc	getPatternSubexpressionPoolSvc()
int	getPriority()
ResultSetProcessorHelperFactory	getResultSetProcessorHelperFactory()
RowRecogStatePoolStmtSvc	getRowRecogStatePoolStmtSvc()
RowRecogStateRepoFactory	getRowRecogStateRepoFactory()
Object	getRuntime()
Context	getRuntimeEnvContext()
RuntimeExtensionServices	getRuntimeExtensionServices()
RuntimeSettingsService	getRuntimeSettingsService()
String	getRuntimeURI()
ScheduleBucket	getScheduleBucket()
SchedulingService	getSchedulingService()
StatementAgentInstanceLockFactory	getStatementAgentInstanceLockFactory()
StatementAIFactoryProvider	getStatementAIFactoryProvider()
StatementAIResourceRegistry	getStatementAIResourceRegistry()
StatementContextFilterEvalEnv	getStatementContextFilterEvalEnv()
StatementContextRuntimeServices	getStatementContextRuntimeServices()
StatementCPCacheService	getStatementCPCacheService()
int	getStatementId()
StatementInformationalsRuntime	getStatementInformationals()
String	getStatementName()
StatementResourceService	getStatementResourceService()
StatementResultService	getStatementResultService()
StatementType	getStatementType()
TableExprEvaluatorContext	getTableExprEvaluatorContext()
TableManagementService	getTableManagementService()
TimeProvider	getTimeProvider()
UpdateDispatchView	getUpdateDispatchView()
Object	getUserObjectCompileTime()
Object	getUserObjectRuntime()
VariableManagementService	getVariableManagementService()
ViewFactoryService	getViewFactoryService()
ViewServicePreviousFactory	getViewServicePreviousFactory()
boolean	isStatelessSelect()
AgentInstanceContext	makeAgentInstanceContextUnpartitioned()
void	setDestroyCallback(StatementDestroyCallback destroyCallback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatementContext

public StatementContext(ContextRuntimeDescriptor contextRuntimeDescriptor,
                        String deploymentId,
                        int statementId,
                        String statementName,
                        String moduleName,
                        StatementInformationalsRuntime statementInformationals,
                        Object userObjectRuntime,
                        StatementContextRuntimeServices statementContextRuntimeServices,
                        EPStatementHandle epStatementHandle,
                        Map<Integer,FilterSpecActivatable> filterSpecActivatables,
                        PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
                        RowRecogStatePoolStmtSvc rowRecogStatePoolStmtSvc,
                        ScheduleBucket scheduleBucket,
                        StatementAIResourceRegistry statementAIResourceRegistry,
                        StatementCPCacheService statementCPCacheService,
                        StatementAIFactoryProvider statementAIFactoryProvider,
                        StatementResultService statementResultService,
                        UpdateDispatchView updateDispatchView)

Method Detail

getAnnotations

public Annotation[] getAnnotations()

getContextName

public String getContextName()

getContextRuntimeDescriptor

public ContextRuntimeDescriptor getContextRuntimeDescriptor()

getContextServiceFactory

public ContextServiceFactory getContextServiceFactory()

getRuntimeSettingsService

public RuntimeSettingsService getRuntimeSettingsService()

getDeploymentId

public String getDeploymentId()

Specified by:

getDeploymentId in interface ExprEvaluatorContext

getEpStatementHandle

public EPStatementHandle getEpStatementHandle()

getRuntimeExtensionServices

public RuntimeExtensionServices getRuntimeExtensionServices()

getEventBeanTypedEventFactory

public EventBeanTypedEventFactory getEventBeanTypedEventFactory()

getEventBeanService

public EventBeanService getEventBeanService()

Specified by:

getEventBeanService in interface ExprEvaluatorContext

getRuntimeURI

public String getRuntimeURI()

Specified by:

getRuntimeURI in interface ExprEvaluatorContext

getExpressionResultCacheServiceSharable

public ExpressionResultCacheService getExpressionResultCacheServiceSharable()

getClasspathImportServiceRuntime

public ClasspathImportServiceRuntime getClasspathImportServiceRuntime()

getEventTableIndexService

public EventTableIndexService getEventTableIndexService()

getEventTypeRepositoryPreconfigured

public EventTypeRepositoryImpl getEventTypeRepositoryPreconfigured()

getFilterService

public FilterService getFilterService()

getFilterBooleanExpressionFactory

public FilterBooleanExpressionFactory getFilterBooleanExpressionFactory()

getFilterSharedLookupableRepository

public FilterSharedLookupableRepository getFilterSharedLookupableRepository()

getFilterSharedBoolExprRepository

public FilterSharedBoolExprRepository getFilterSharedBoolExprRepository()

getFilterSpecActivatables

public Map<Integer,FilterSpecActivatable> getFilterSpecActivatables()

getInternalEventRouter

public InternalEventRouter getInternalEventRouter()

getInternalEventRouteDest

public InternalEventRouteDest getInternalEventRouteDest()

getNamedWindowConsumerManagementService

public NamedWindowConsumerManagementService getNamedWindowConsumerManagementService()

getNamedWindowManagementService

public NamedWindowManagementService getNamedWindowManagementService()

getPriority

public int getPriority()

getResultSetProcessorHelperFactory

public ResultSetProcessorHelperFactory getResultSetProcessorHelperFactory()

getStatementId

public int getStatementId()

Specified by:

getStatementId in interface ExprEvaluatorContext

getStatementCPCacheService

public StatementCPCacheService getStatementCPCacheService()

getStatementContextRuntimeServices

public StatementContextRuntimeServices getStatementContextRuntimeServices()

getSchedulingService

public SchedulingService getSchedulingService()

getStatementName

public String getStatementName()

Specified by:

getStatementName in interface ExprEvaluatorContext

getStatementAIResourceRegistry

public StatementAIResourceRegistry getStatementAIResourceRegistry()

getStatementAIFactoryProvider

public StatementAIFactoryProvider getStatementAIFactoryProvider()

getScheduleBucket

public ScheduleBucket getScheduleBucket()

isStatelessSelect

public boolean isStatelessSelect()

getStatementAgentInstanceLockFactory

public StatementAgentInstanceLockFactory getStatementAgentInstanceLockFactory()

getStatementResultService

public StatementResultService getStatementResultService()

getTableManagementService

public TableManagementService getTableManagementService()

getTimeProvider

public TimeProvider getTimeProvider()

Specified by:

getTimeProvider in interface ExprEvaluatorContext

getUserObjectCompileTime

public Object getUserObjectCompileTime()

Specified by:

getUserObjectCompileTime in interface ExprEvaluatorContext

getUpdateDispatchView

public UpdateDispatchView getUpdateDispatchView()

getViewServicePreviousFactory

public ViewServicePreviousFactory getViewServicePreviousFactory()

getViewFactoryService

public ViewFactoryService getViewFactoryService()

getStatementResourceService

public StatementResourceService getStatementResourceService()

getPathContextRegistry

public PathRegistry<String,ContextMetaData> getPathContextRegistry()

getPatternSubexpressionPoolSvc

public PatternSubexpressionPoolStmtSvc getPatternSubexpressionPoolSvc()

getStatementInformationals

public StatementInformationalsRuntime getStatementInformationals()

addFinalizeCallback

public void addFinalizeCallback(StatementFinalizeCallback callback)

getFinalizeCallbacks

public Iterator<StatementFinalizeCallback> getFinalizeCallbacks()

getExceptionHandlingService

public ExceptionHandlingService getExceptionHandlingService()

makeAgentInstanceContextUnpartitioned

public AgentInstanceContext makeAgentInstanceContextUnpartitioned()

getContextManagementService

public ContextManagementService getContextManagementService()

getVariableManagementService

public VariableManagementService getVariableManagementService()

getStatementContextFilterEvalEnv

public StatementContextFilterEvalEnv getStatementContextFilterEvalEnv()

getDestroyCallback

public StatementDestroyCallback getDestroyCallback()

setDestroyCallback

public void setDestroyCallback(StatementDestroyCallback destroyCallback)

getTableExprEvaluatorContext

public TableExprEvaluatorContext getTableExprEvaluatorContext()

Specified by:

getTableExprEvaluatorContext in interface ExprEvaluatorContext

getContextProperties

public EventBean getContextProperties()

Specified by:

getContextProperties in interface ExprEvaluatorContext

getAgentInstanceId

public int getAgentInstanceId()

Specified by:

getAgentInstanceId in interface ExprEvaluatorContext

getAgentInstanceLock

public StatementAgentInstanceLock getAgentInstanceLock()

Specified by:

getAgentInstanceLock in interface ExprEvaluatorContext

getExpressionResultCacheService

public ExpressionResultCacheService getExpressionResultCacheService()

Specified by:

getExpressionResultCacheService in interface ExprEvaluatorContext

getAllocateAgentInstanceScriptContext

public AgentInstanceScriptContext getAllocateAgentInstanceScriptContext()

Specified by:

getAllocateAgentInstanceScriptContext in interface ExprEvaluatorContext

getEventTypeResolvingBeanFactory

public EventTypeResolvingBeanFactory getEventTypeResolvingBeanFactory()

getEventTypePathRegistry

public PathRegistry<String,EventType> getEventTypePathRegistry()

getEventTypeAvroHandler

public EventTypeAvroHandler getEventTypeAvroHandler()

getRuntime

public Object getRuntime()

getRowRecogStatePoolStmtSvc

public RowRecogStatePoolStmtSvc getRowRecogStatePoolStmtSvc()

getRowRecogStateRepoFactory

public RowRecogStateRepoFactory getRowRecogStateRepoFactory()

getHistoricalDataCacheFactory

public HistoricalDataCacheFactory getHistoricalDataCacheFactory()

getDatabaseConfigService

public DatabaseConfigServiceRuntime getDatabaseConfigService()

getEPRuntimeEventProcessWrapped

public EPRuntimeEventProcessWrapped getEPRuntimeEventProcessWrapped()

getEPRuntimeSendEvent

public EventServiceSendEventCommon getEPRuntimeSendEvent()

getEPRuntimeRenderEvent

public EPRenderEventService getEPRuntimeRenderEvent()

getDataFlowFilterServiceAdapter

public DataFlowFilterServiceAdapter getDataFlowFilterServiceAdapter()

getMetricReportingService

public MetricReportingService getMetricReportingService()

getAuditProvider

public AuditProvider getAuditProvider()

Specified by:

getAuditProvider in interface ExprEvaluatorContext

getInstrumentationProvider

public InstrumentationCommon getInstrumentationProvider()

Specified by:

getInstrumentationProvider in interface ExprEvaluatorContext

getRuntimeEnvContext

public Context getRuntimeEnvContext()

getUserObjectRuntime

public Object getUserObjectRuntime()

getStatementType

public StatementType getStatementType()

getModuleName

public String getModuleName()