com.espertech.esper.core.service
Class StatementContext

java.lang.Object
  com.espertech.esper.core.service.StatementContext

public final class StatementContext
extends java.lang.Object

Contains handles to the implementation of the the scheduling service for use in view evaluation.

Constructor Summary

StatementContext(StatementContextEngineServices stmtEngineServices, SchedulingService schedulingService, ScheduleBucket scheduleBucket, EPStatementHandle epStatementHandle, ViewResolutionService viewResultionService, PatternObjectResolutionService patternResolutionService, StatementExtensionSvcContext statementExtensionSvcContext, StatementStopService statementStopService, MethodResolutionService methodResolutionService, PatternContextFactory patternContextFactory, FilterService filterService, StatementResultService statementResultService, InternalEventRouteDest internalEventEngineRouteDest, java.lang.annotation.Annotation[] annotations, StatementAIResourceRegistry statementAgentInstanceRegistry, StatementAgentInstanceLock defaultAgentInstanceLock, ContextDescriptor contextDescriptor, PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc, MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc, boolean statelessSelect, ContextControllerFactoryService contextControllerFactoryService, AgentInstanceScriptContext defaultAgentInstanceScriptContext, AggregationServiceFactoryService aggregationServiceFactoryService, boolean writesToTables, java.lang.Object statementUserObject, StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry, int priority)
Constructor.

Method Summary

int	getAgentInstanceId()
AggregationServiceFactoryService	getAggregationServiceFactoryService()
java.lang.annotation.Annotation[]	getAnnotations()
ConfigurationInformation	getConfigSnapshot() Returns the configuration.
ContextControllerFactoryService	getContextControllerFactoryService()
ContextDescriptor	getContextDescriptor()
ContextManagementService	getContextManagementService()
java.lang.String	getContextName()
StatementAgentInstanceLock	getDefaultAgentInstanceLock()
AgentInstanceScriptContext	getDefaultAgentInstanceScriptContext()
EngineLevelExtensionServicesContext	getEngineExtensionServicesContext()
EngineSettingsService	getEngineSettingsService()
java.lang.String	getEngineURI() Returns the engine URI.
EPStatementHandle	getEpStatementHandle() Returns the statement's resource locks.
EventAdapterService	getEventAdapterService() Returns service for generating events and handling event types.
EventTableIndexService	getEventTableIndexService()
ExceptionHandlingService	getExceptionHandlingService()
java.lang.String	getExpression() Returns the statement expression text
ExpressionResultCacheService	getExpressionResultCacheServiceSharable()
FilterBooleanExpressionFactory	getFilterBooleanExpressionFactory()
FilterFaultHandlerFactory	getFilterFaultHandlerFactory()
FilterService	getFilterService() Returns the filter service.
InternalEventRouteDest	getInternalEventEngineRouteDest() Returns the internal event router.
MatchRecognizeStatePoolStmtSvc	getMatchRecognizeStatePoolStmtSvc()
MethodResolutionService	getMethodResolutionService() Returns service to look up static and aggregation methods or functions.
MetricReportingServiceSPI	getMetricReportingService() Returns metrics svc.
NamedWindowMgmtService	getNamedWindowMgmtService() Returns the named window management service.
PatternContextFactory	getPatternContextFactory() Returns the pattern context factory for the statement.
PatternNodeFactory	getPatternNodeFactory()
PatternObjectResolutionService	getPatternResolutionService() Returns the statement's resolution service for pattern objects.
PatternSubexpressionPoolStmtSvc	getPatternSubexpressionPoolSvc()
java.net.URI[]	getPlugInTypeResolutionURIs() Returns the URIs for resolving the event name against plug-inn event representations, if any
int	getPriority()
RegexHandlerFactory	getRegexPartitionStateRepoFactory()
ScheduleAdjustmentService	getScheduleAdjustmentService() Return the service for adjusting schedules.
ScheduleBucket	getScheduleBucket() Returns the schedule bucket for ordering schedule callbacks within this pattern.
SchedulingService	getSchedulingService() Returns service to use for schedule evaluation.
EPStatementSPI	getStatement()
StatementAgentInstanceFactory	getStatementAgentInstanceFactory()
StatementAIResourceRegistry	getStatementAgentInstanceRegistry()
StatementEventTypeRef	getStatementEventTypeRef()
StatementExtensionSvcContext	getStatementExtensionServicesContext() Returns extension context for statements.
int	getStatementId() Returns the statement id.
StatementLockFactory	getStatementLockFactory()
java.lang.String	getStatementName() Returns the statement name
StatementResultService	getStatementResultService() Returns the service that handles awareness of listeners/subscriptions for a statement customizing output produced
StatementSemiAnonymousTypeRegistry	getStatementSemiAnonymousTypeRegistry()
StatementSpecCompiled	getStatementSpecCompiled()
StatementStopService	getStatementStopService() Returns statement stop subscription taker.
StatementType	getStatementType()
java.lang.Object	getStatementUserObject()
TableExprEvaluatorContext	getTableExprEvaluatorContext()
TableService	getTableService() Returns table service.
TimeProvider	getTimeProvider() Returns the time provider.
TimeSourceService	getTimeSourceService()
ValueAddEventService	getValueAddEventService() Returns the update event service.
VariableService	getVariableService() Returns variable service.
ViewResolutionService	getViewResolutionService() Returns view resolution svc.
ViewService	getViewService() Returns view svc.
ViewServicePreviousFactory	getViewServicePreviousFactory()
boolean	isStatelessSelect()
boolean	isWritesToTables()
void	setDefaultAgentInstanceLock(StatementAgentInstanceLock defaultAgentInstanceLock)
void	setFilterFaultHandlerFactory(FilterFaultHandlerFactory filterFaultHandlerFactory)
void	setFilterService(FilterService filterService) Sets the filter service
void	setInternalEventEngineRouteDest(InternalEventRouteDest internalEventEngineRouteDest) Sets the internal event router.
void	setSchedulingService(SchedulingService schedulingService) Sets the scheduling service
void	setStatement(EPStatementSPI statement)
void	setStatementAgentInstanceFactory(StatementAgentInstanceFactory statementAgentInstanceFactory)
void	setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementContext

public StatementContext(StatementContextEngineServices stmtEngineServices,
                        SchedulingService schedulingService,
                        ScheduleBucket scheduleBucket,
                        EPStatementHandle epStatementHandle,
                        ViewResolutionService viewResultionService,
                        PatternObjectResolutionService patternResolutionService,
                        StatementExtensionSvcContext statementExtensionSvcContext,
                        StatementStopService statementStopService,
                        MethodResolutionService methodResolutionService,
                        PatternContextFactory patternContextFactory,
                        FilterService filterService,
                        StatementResultService statementResultService,
                        InternalEventRouteDest internalEventEngineRouteDest,
                        java.lang.annotation.Annotation[] annotations,
                        StatementAIResourceRegistry statementAgentInstanceRegistry,
                        StatementAgentInstanceLock defaultAgentInstanceLock,
                        ContextDescriptor contextDescriptor,
                        PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
                        MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
                        boolean statelessSelect,
                        ContextControllerFactoryService contextControllerFactoryService,
                        AgentInstanceScriptContext defaultAgentInstanceScriptContext,
                        AggregationServiceFactoryService aggregationServiceFactoryService,
                        boolean writesToTables,
                        java.lang.Object statementUserObject,
                        StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry,
                        int priority)

Constructor.

Parameters:

stmtEngineServices - is the engine services for the statement

schedulingService - implementation for schedule registration

scheduleBucket - is for ordering scheduled callbacks within the view statements

epStatementHandle - is the statements-own handle for use in registering callbacks with services

viewResultionService - is a service for resolving view namespace and name to a view factory

statementExtensionSvcContext - provide extension points for custom statement resources

statementStopService - for registering a callback invoked when a statement is stopped

methodResolutionService - is a service for resolving static methods and aggregation functions

patternContextFactory - is the pattern-level services and context information factory

filterService - is the filtering service

patternResolutionService - is the service that resolves pattern objects for the statement

statementResultService - handles awareness of listeners/subscriptions for a statement customizing output produced

internalEventEngineRouteDest - routing destination

Method Detail

getStatementType

public StatementType getStatementType()

getStatementId

public int getStatementId()

Returns the statement id.

Returns:

statement id

getStatementName

public java.lang.String getStatementName()

Returns the statement name

Returns:

statement name

getSchedulingService

public final SchedulingService getSchedulingService()

Returns service to use for schedule evaluation.

Returns:

schedule evaluation service implemetation

getEventAdapterService

public EventAdapterService getEventAdapterService()

Returns service for generating events and handling event types.

Returns:

event adapter service

getScheduleBucket

public ScheduleBucket getScheduleBucket()

Returns the schedule bucket for ordering schedule callbacks within this pattern.

Returns:

schedule bucket

getEpStatementHandle

public EPStatementHandle getEpStatementHandle()

Returns the statement's resource locks.

Returns:

statement resource lock/handle

getViewResolutionService

public ViewResolutionService getViewResolutionService()

Returns view resolution svc.

Returns:

view resolution

getStatementExtensionServicesContext

public StatementExtensionSvcContext getStatementExtensionServicesContext()

Returns extension context for statements.

Returns:

context

getStatementStopService

public StatementStopService getStatementStopService()

Returns statement stop subscription taker.

Returns:

stop service

getMethodResolutionService

public MethodResolutionService getMethodResolutionService()

Returns service to look up static and aggregation methods or functions.

Returns:

method resolution

getPatternContextFactory

public PatternContextFactory getPatternContextFactory()

Returns the pattern context factory for the statement.

Returns:

pattern context factory

getExpression

public java.lang.String getExpression()

Returns the statement expression text

Returns:

expression text

getEngineURI

public java.lang.String getEngineURI()

Returns the engine URI.

Returns:

engine URI

getFilterService

public FilterService getFilterService()

Returns the filter service.

Returns:

filter service

getPatternResolutionService

public PatternObjectResolutionService getPatternResolutionService()

Returns the statement's resolution service for pattern objects.

Returns:

service for resolving pattern objects

getNamedWindowMgmtService

public NamedWindowMgmtService getNamedWindowMgmtService()

Returns the named window management service.

Returns:

service for managing named windows

getVariableService

public VariableService getVariableService()

Returns variable service.

Returns:

variable service

getTableService

public TableService getTableService()

Returns table service.

Returns:

table service

getStatementResultService

public StatementResultService getStatementResultService()

Returns the service that handles awareness of listeners/subscriptions for a statement customizing output produced

Returns:

statement result svc

getPlugInTypeResolutionURIs

public java.net.URI[] getPlugInTypeResolutionURIs()

Returns the URIs for resolving the event name against plug-inn event representations, if any

Returns:

URIs

getValueAddEventService

public ValueAddEventService getValueAddEventService()

Returns the update event service.

Returns:

revision service

getConfigSnapshot

public ConfigurationInformation getConfigSnapshot()

Returns the configuration.

Returns:

configuration

setSchedulingService

public void setSchedulingService(SchedulingService schedulingService)

Sets the scheduling service

Parameters:

schedulingService - service

setFilterService

public void setFilterService(FilterService filterService)

Sets the filter service

Parameters:

filterService - filter service

getInternalEventEngineRouteDest

public InternalEventRouteDest getInternalEventEngineRouteDest()

Returns the internal event router.

Returns:

router

setInternalEventEngineRouteDest

public void setInternalEventEngineRouteDest(InternalEventRouteDest internalEventEngineRouteDest)

Sets the internal event router.

Parameters:

internalEventEngineRouteDest - router

getScheduleAdjustmentService

public ScheduleAdjustmentService getScheduleAdjustmentService()

Return the service for adjusting schedules.

Returns:

service for adjusting schedules, or null if not applicable

getMetricReportingService

public MetricReportingServiceSPI getMetricReportingService()

Returns metrics svc.

Returns:

metrics

getTimeProvider

public TimeProvider getTimeProvider()

Returns the time provider.

Returns:

time provider

getViewService

public ViewService getViewService()

Returns view svc.

Returns:

svc

getExceptionHandlingService

public ExceptionHandlingService getExceptionHandlingService()

getTableExprEvaluatorContext

public TableExprEvaluatorContext getTableExprEvaluatorContext()

getContextManagementService

public ContextManagementService getContextManagementService()

getAnnotations

public java.lang.annotation.Annotation[] getAnnotations()

getExpressionResultCacheServiceSharable

public ExpressionResultCacheService getExpressionResultCacheServiceSharable()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getAgentInstanceId

public int getAgentInstanceId()

getStatementAgentInstanceRegistry

public StatementAIResourceRegistry getStatementAgentInstanceRegistry()

getDefaultAgentInstanceLock

public StatementAgentInstanceLock getDefaultAgentInstanceLock()

getContextDescriptor

public ContextDescriptor getContextDescriptor()

setDefaultAgentInstanceLock

public void setDefaultAgentInstanceLock(StatementAgentInstanceLock defaultAgentInstanceLock)

getPatternSubexpressionPoolSvc

public PatternSubexpressionPoolStmtSvc getPatternSubexpressionPoolSvc()

getMatchRecognizeStatePoolStmtSvc

public MatchRecognizeStatePoolStmtSvc getMatchRecognizeStatePoolStmtSvc()

isStatelessSelect

public boolean isStatelessSelect()

getContextControllerFactoryService

public ContextControllerFactoryService getContextControllerFactoryService()

getDefaultAgentInstanceScriptContext

public AgentInstanceScriptContext getDefaultAgentInstanceScriptContext()

getAggregationServiceFactoryService

public AggregationServiceFactoryService getAggregationServiceFactoryService()

getStatementEventTypeRef

public StatementEventTypeRef getStatementEventTypeRef()

getContextName

public java.lang.String getContextName()

isWritesToTables

public boolean isWritesToTables()

getStatementUserObject

public java.lang.Object getStatementUserObject()

getEngineExtensionServicesContext

public EngineLevelExtensionServicesContext getEngineExtensionServicesContext()

getRegexPartitionStateRepoFactory

public RegexHandlerFactory getRegexPartitionStateRepoFactory()

getViewServicePreviousFactory

public ViewServicePreviousFactory getViewServicePreviousFactory()

getPatternNodeFactory

public PatternNodeFactory getPatternNodeFactory()

getEventTableIndexService

public EventTableIndexService getEventTableIndexService()

getStatementLockFactory

public StatementLockFactory getStatementLockFactory()

setStatementSpecCompiled

public void setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled)

getStatementSpecCompiled

public StatementSpecCompiled getStatementSpecCompiled()

setStatementAgentInstanceFactory

public void setStatementAgentInstanceFactory(StatementAgentInstanceFactory statementAgentInstanceFactory)

getStatementAgentInstanceFactory

public StatementAgentInstanceFactory getStatementAgentInstanceFactory()

getStatement

public EPStatementSPI getStatement()

setStatement

public void setStatement(EPStatementSPI statement)

getStatementSemiAnonymousTypeRegistry

public StatementSemiAnonymousTypeRegistry getStatementSemiAnonymousTypeRegistry()

getFilterBooleanExpressionFactory

public FilterBooleanExpressionFactory getFilterBooleanExpressionFactory()

getEngineSettingsService

public EngineSettingsService getEngineSettingsService()

getPriority

public int getPriority()

getFilterFaultHandlerFactory

public FilterFaultHandlerFactory getFilterFaultHandlerFactory()

setFilterFaultHandlerFactory

public void setFilterFaultHandlerFactory(FilterFaultHandlerFactory filterFaultHandlerFactory)

getTimeSourceService

public TimeSourceService getTimeSourceService()