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

Class AgentInstanceContext

java.lang.Object

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

All Implemented Interfaces:

ExprEvaluatorContext

public class AgentInstanceContext
extends Object
implements ExprEvaluatorContext

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor	Description
AgentInstanceContext(StatementContext statementContext, EPStatementAgentInstanceHandle epStatementAgentInstanceHandle, AgentInstanceFilterProxy agentInstanceFilterProxy, MappedEventBean contextProperties, AuditProvider auditProvider, InstrumentationCommon instrumentationProvider)

Method Summary

Modifier and Type	Method	Description
void	addTerminationCallback(AgentInstanceMgmtCallback callback)	Add a stop-callback.
AgentInstanceFilterProxy	getAgentInstanceFilterProxy()
int	getAgentInstanceId()
StatementAgentInstanceLock	getAgentInstanceLock()
AgentInstanceScriptContext	getAllocateAgentInstanceScriptContext()
Annotation[]	getAnnotations()
AuditProvider	getAuditProvider()
ClasspathImportServiceRuntime	getClasspathImportServiceRuntime()
Configuration	getConfigSnapshot()
ContextManagementService	getContextManagementService()
String	getContextName()
EventBean	getContextProperties()
ContextServiceFactory	getContextServiceFactory()
DatabaseConfigServiceRuntime	getDatabaseConfigService()
DataFlowFilterServiceAdapter	getDataFlowFilterServiceAdapter()
String	getDeploymentId()
String	getEPLWhenAvailable()
EPRuntimeEventProcessWrapped	getEPRuntimeEventProcessWrapped()
EPRenderEventService	getEPRuntimeRenderEvent()
EventServiceSendEventCommon	getEPRuntimeSendEvent()
EPStatementAgentInstanceHandle	getEpStatementAgentInstanceHandle()
EventBeanService	getEventBeanService()
EventBeanTypedEventFactory	getEventBeanTypedEventFactory()
EventTableIndexService	getEventTableIndexService()
EventTypeAvroHandler	getEventTypeAvroHandler()
EventTypeResolvingBeanFactory	getEventTypeResolvingBeanFactory()
ExceptionHandlingService	getExceptionHandlingService()
ExpressionResultCacheService	getExpressionResultCacheService()
Object	getFilterReboolConstant()
FilterService	getFilterService()
long	getFilterVersionAfterAllocation()
HistoricalDataCacheFactory	getHistoricalDataCacheFactory()
InstrumentationCommon	getInstrumentationProvider()
InternalEventRouteDest	getInternalEventRouteDest()
InternalEventRouter	getInternalEventRouter()
MetricReportingService	getMetricReportingService()
String	getModuleName()
NamedWindowManagementService	getNamedWindowManagementService()
ResultSetProcessorHelperFactory	getResultSetProcessorHelperFactory()
RowRecogStateRepoFactory	getRowRecogStateRepoFactory()
Object	getRuntime()
Context	getRuntimeEnvContext()
RuntimeExtensionServices	getRuntimeExtensionServicesContext()
RuntimeSettingsService	getRuntimeSettingsService()
String	getRuntimeURI()
ScheduleBucket	getScheduleBucket()
SchedulingService	getSchedulingService()
StatementContext	getStatementContext()
StatementContextCPPair	getStatementContextCPPair()
StatementContextFilterEvalEnv	getStatementContextFilterEvalEnv()
int	getStatementId()
String	getStatementName()
StatementResourceService	getStatementResourceService()
StatementResultService	getStatementResultService()
TableExprEvaluatorContext	getTableExprEvaluatorContext()
TableManagementService	getTableManagementService()
Collection<AgentInstanceMgmtCallback>	getTerminationCallbackRO()
TimeAbacus	getTimeAbacus()
TimeProvider	getTimeProvider()
TimeZone	getTimeZone()
Object	getUserObjectCompileTime()
VariableManagementService	getVariableManagementService()
ViewFactoryService	getViewFactoryService()
boolean	isWritesToTables()
void	removeTerminationCallback(AgentInstanceMgmtCallback callback)
void	setFilterReboolConstant(Object value)

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

AgentInstanceContext

public AgentInstanceContext(StatementContext statementContext,
 EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
 AgentInstanceFilterProxy agentInstanceFilterProxy,
 MappedEventBean contextProperties,
 AuditProvider auditProvider,
 InstrumentationCommon instrumentationProvider)

Method Details

getAgentInstanceFilterProxy

public AgentInstanceFilterProxy getAgentInstanceFilterProxy()

getAnnotations

public Annotation[] getAnnotations()

Specified by:

getAnnotations in interface ExprEvaluatorContext

getContextManagementService

public ContextManagementService getContextManagementService()

getContextServiceFactory

public ContextServiceFactory getContextServiceFactory()

getContextProperties

public EventBean getContextProperties()

Specified by:

getContextProperties in interface ExprEvaluatorContext

getRuntimeURI

public String getRuntimeURI()

Specified by:

getRuntimeURI in interface ExprEvaluatorContext

getAgentInstanceId

public int getAgentInstanceId()

Specified by:

getAgentInstanceId in interface ExprEvaluatorContext

getAgentInstanceLock

public StatementAgentInstanceLock getAgentInstanceLock()

Specified by:

getAgentInstanceLock in interface ExprEvaluatorContext

getEpStatementAgentInstanceHandle

public EPStatementAgentInstanceHandle getEpStatementAgentInstanceHandle()

getRuntimeExtensionServicesContext

public RuntimeExtensionServices getRuntimeExtensionServicesContext()

getEventBeanTypedEventFactory

public EventBeanTypedEventFactory getEventBeanTypedEventFactory()

Specified by:

getEventBeanTypedEventFactory in interface ExprEvaluatorContext

getRuntimeSettingsService

public RuntimeSettingsService getRuntimeSettingsService()

getClasspathImportServiceRuntime

public ClasspathImportServiceRuntime getClasspathImportServiceRuntime()

getEventBeanService

public EventBeanService getEventBeanService()

Specified by:

getEventBeanService in interface ExprEvaluatorContext

getFilterService

public FilterService getFilterService()

getInternalEventRouter

public InternalEventRouter getInternalEventRouter()

getInternalEventRouteDest

public InternalEventRouteDest getInternalEventRouteDest()

getSchedulingService

public SchedulingService getSchedulingService()

getScheduleBucket

public ScheduleBucket getScheduleBucket()

getStatementName

public String getStatementName()

Specified by:

getStatementName in interface ExprEvaluatorContext

getUserObjectCompileTime

public Object getUserObjectCompileTime()

Specified by:

getUserObjectCompileTime in interface ExprEvaluatorContext

getStatementId

public int getStatementId()

Specified by:

getStatementId in interface ExprEvaluatorContext

getStatementContextCPPair

public StatementContextCPPair getStatementContextCPPair()

getStatementContext

public StatementContext getStatementContext()

getStatementResultService

public StatementResultService getStatementResultService()

getTimeProvider

public TimeProvider getTimeProvider()

Specified by:

getTimeProvider in interface ExprEvaluatorContext

getViewFactoryService

public ViewFactoryService getViewFactoryService()

getResultSetProcessorHelperFactory

public ResultSetProcessorHelperFactory getResultSetProcessorHelperFactory()

getDeploymentId

public String getDeploymentId()

Specified by:

getDeploymentId in interface ExprEvaluatorContext

getNamedWindowManagementService

public NamedWindowManagementService getNamedWindowManagementService()

getStatementResourceService

public StatementResourceService getStatementResourceService()

getExpressionResultCacheService

public ExpressionResultCacheService getExpressionResultCacheService()

Specified by:

getExpressionResultCacheService in interface ExprEvaluatorContext

getExceptionHandlingService

public ExceptionHandlingService getExceptionHandlingService()

Specified by:

getExceptionHandlingService in interface ExprEvaluatorContext

getVariableManagementService

public VariableManagementService getVariableManagementService()

Specified by:

getVariableManagementService in interface ExprEvaluatorContext

getStatementContextFilterEvalEnv

public StatementContextFilterEvalEnv getStatementContextFilterEvalEnv()

getTableExprEvaluatorContext

public TableExprEvaluatorContext getTableExprEvaluatorContext()

Specified by:

getTableExprEvaluatorContext in interface ExprEvaluatorContext

getTableManagementService

public TableManagementService getTableManagementService()

getAllocateAgentInstanceScriptContext

public AgentInstanceScriptContext getAllocateAgentInstanceScriptContext()

Specified by:

getAllocateAgentInstanceScriptContext in interface ExprEvaluatorContext

getEventTypeResolvingBeanFactory

public EventTypeResolvingBeanFactory getEventTypeResolvingBeanFactory()

getEventTypeAvroHandler

public EventTypeAvroHandler getEventTypeAvroHandler()

getRowRecogStateRepoFactory

public RowRecogStateRepoFactory getRowRecogStateRepoFactory()

getEventTableIndexService

public EventTableIndexService getEventTableIndexService()

getHistoricalDataCacheFactory

public HistoricalDataCacheFactory getHistoricalDataCacheFactory()

getDatabaseConfigService

public DatabaseConfigServiceRuntime getDatabaseConfigService()

getEPRuntimeEventProcessWrapped

public EPRuntimeEventProcessWrapped getEPRuntimeEventProcessWrapped()

getEPRuntimeSendEvent

public EventServiceSendEventCommon getEPRuntimeSendEvent()

getEPRuntimeRenderEvent

public EPRenderEventService getEPRuntimeRenderEvent()

getDataFlowFilterServiceAdapter

public DataFlowFilterServiceAdapter getDataFlowFilterServiceAdapter()

getRuntime

public Object getRuntime()

getMetricReportingService

public MetricReportingService getMetricReportingService()

getAuditProvider

public AuditProvider getAuditProvider()

Specified by:

getAuditProvider in interface ExprEvaluatorContext

getInstrumentationProvider

public InstrumentationCommon getInstrumentationProvider()

Specified by:

getInstrumentationProvider in interface ExprEvaluatorContext

getTerminationCallbackRO

public Collection<AgentInstanceMgmtCallback> getTerminationCallbackRO()

addTerminationCallback

public void addTerminationCallback(AgentInstanceMgmtCallback callback)

Add a stop-callback. Use to add a stop-callback other than already registered. This is generally not required by views that implement AgentInstanceStopCallback as they gets stopped as part of normal processing.

Parameters:

callback - to add

removeTerminationCallback

public void removeTerminationCallback(AgentInstanceMgmtCallback callback)

getRuntimeEnvContext

public Context getRuntimeEnvContext()

getFilterVersionAfterAllocation

public long getFilterVersionAfterAllocation()

getModuleName

public String getModuleName()

Specified by:

getModuleName in interface ExprEvaluatorContext

getContextName

public String getContextName()

Specified by:

getContextName in interface ExprEvaluatorContext

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

getFilterReboolConstant

public Object getFilterReboolConstant()

Specified by:

getFilterReboolConstant in interface ExprEvaluatorContext

setFilterReboolConstant

public void setFilterReboolConstant(Object value)

Specified by:

setFilterReboolConstant in interface ExprEvaluatorContext