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

Class StatementContext

java.lang.Object

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

All Implemented Interfaces:

ExprEvaluatorContext, EventTableFactoryFactoryContext, SubSelectStrategyFactoryContext

public class StatementContext
extends Object
implements ExprEvaluatorContext, SubSelectStrategyFactoryContext, EventTableFactoryFactoryContext

Field Summary

Fields inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext

EPTYPE

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, FilterService filterService, SchedulingService schedulingService, InternalEventRouteDest internalEventRouteDest)

Method Summary

Modifier and Type	Method and Description
void	addFinalizeCallback(StatementFinalizeCallback callback)
int	getAgentInstanceId()
StatementAgentInstanceLock	getAgentInstanceLock()
AgentInstanceScriptContext	getAllocateAgentInstanceScriptContext()
Annotation[]	getAnnotations()
AuditProvider	getAuditProvider()
ClasspathImportServiceRuntime	getClasspathImportServiceRuntime()
Configuration	getConfigSnapshot()
ContextManagementService	getContextManagementService()
String	getContextName()
EventBean	getContextProperties()
ContextRuntimeDescriptor	getContextRuntimeDescriptor()
ContextServiceFactory	getContextServiceFactory()
DatabaseConfigServiceRuntime	getDatabaseConfigService()
DataFlowFilterServiceAdapter	getDataFlowFilterServiceAdapter()
String	getDeploymentId()
StatementDestroyCallback	getDestroyCallback()
String	getEPLWhenAvailable()
EPRuntimeEventProcessWrapped	getEPRuntimeEventProcessWrapped()
EPRenderEventService	getEPRuntimeRenderEvent()
EventServiceSendEventCommon	getEPRuntimeSendEvent()
EPStatementHandle	getEpStatementHandle()
EventBeanService	getEventBeanService()
EventBeanTypedEventFactory	getEventBeanTypedEventFactory()
EventTableFactoryFactoryContext	getEventTableFactoryContext()
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()
TimeAbacus	getTimeAbacus()
TimeProvider	getTimeProvider()
TimeZone	getTimeZone()
UpdateDispatchView	getUpdateDispatchView()
Object	getUserObjectCompileTime()
Object	getUserObjectRuntime()
VariableManagementService	getVariableManagementService()
ViewFactoryService	getViewFactoryService()
ViewServicePreviousFactory	getViewServicePreviousFactory()
boolean	isStatelessSelect()
boolean	isWritesToTables()
AgentInstanceContext	makeAgentInstanceContextUnpartitioned()
void	setDestroyCallback(StatementDestroyCallback destroyCallback)
void	setFilterService(FilterService filterService)
void	setInternalEventRouteDest(InternalEventRouteDest internalEventRouteDest)
void	setSchedulingService(SchedulingService schedulingService)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext

getFilterReboolConstant, setFilterReboolConstant

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,
                        FilterService filterService,
                        SchedulingService schedulingService,
                        InternalEventRouteDest internalEventRouteDest)

Method Detail

getAnnotations

public Annotation[] getAnnotations()

Specified by:

getAnnotations in interface ExprEvaluatorContext

Specified by:

getAnnotations in interface EventTableFactoryFactoryContext

getContextName

public String getContextName()

Specified by:

getContextName in interface ExprEvaluatorContext

getContextRuntimeDescriptor

public ContextRuntimeDescriptor getContextRuntimeDescriptor()

getContextServiceFactory

public ContextServiceFactory getContextServiceFactory()

getRuntimeSettingsService

public RuntimeSettingsService getRuntimeSettingsService()

Specified by:

getRuntimeSettingsService in interface EventTableFactoryFactoryContext

getDeploymentId

public String getDeploymentId()

Specified by:

getDeploymentId in interface ExprEvaluatorContext

getEpStatementHandle

public EPStatementHandle getEpStatementHandle()

getRuntimeExtensionServices

public RuntimeExtensionServices getRuntimeExtensionServices()

getEventBeanTypedEventFactory

public EventBeanTypedEventFactory getEventBeanTypedEventFactory()

Specified by:

getEventBeanTypedEventFactory in interface ExprEvaluatorContext

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()

Specified by:

getEventTableIndexService in interface EventTableFactoryFactoryContext

Specified by:

getEventTableIndexService in interface SubSelectStrategyFactoryContext

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()

Specified by:

getExceptionHandlingService in interface ExprEvaluatorContext

makeAgentInstanceContextUnpartitioned

public AgentInstanceContext makeAgentInstanceContextUnpartitioned()

getContextManagementService

public ContextManagementService getContextManagementService()

getVariableManagementService

public VariableManagementService getVariableManagementService()

Specified by:

getVariableManagementService in interface ExprEvaluatorContext

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()

Specified by:

getModuleName in interface ExprEvaluatorContext

getEventTableFactoryContext

public EventTableFactoryFactoryContext getEventTableFactoryContext()

Specified by:

getEventTableFactoryContext in interface SubSelectStrategyFactoryContext

setFilterService

public void setFilterService(FilterService filterService)

setSchedulingService

public void setSchedulingService(SchedulingService schedulingService)

setInternalEventRouteDest

public void setInternalEventRouteDest(InternalEventRouteDest internalEventRouteDest)

getEPLWhenAvailable

public String getEPLWhenAvailable()

Specified by:

getEPLWhenAvailable in interface ExprEvaluatorContext

getTimeZone

public TimeZone getTimeZone()

Specified by:

getTimeZone in interface ExprEvaluatorContext

getTimeAbacus

public TimeAbacus getTimeAbacus()

Specified by:

getTimeAbacus in interface ExprEvaluatorContext

isWritesToTables

public boolean isWritesToTables()

Specified by:

isWritesToTables in interface ExprEvaluatorContext

getConfigSnapshot

public Configuration getConfigSnapshot()