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, byte[] statementIdBytes, 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, boolean statelessSelect, ContextControllerFactoryService contextControllerFactoryService, AgentInstanceScriptContext defaultAgentInstanceScriptContext, AggregationServiceFactoryService aggregationServiceFactoryService, boolean writesToTables, java.lang.Object statementUserObject)
Constructor.

Method Summary

int	getAgentInstanceId()
AggregationServiceFactoryService	getAggregationServiceFactoryService()
java.lang.annotation.Annotation[]	getAnnotations()
ConfigurationInformation	getConfigSnapshot() Returns the configuration.
ContextControllerFactoryService	getContextControllerFactoryService()
ContextDescriptor	getContextDescriptor()
java.lang.String	getContextName()
StatementAgentInstanceLock	getDefaultAgentInstanceLock()
AgentInstanceScriptContext	getDefaultAgentInstanceScriptContext()
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.
ExceptionHandlingService	getExceptionHandlingService()
java.lang.String	getExpression() Returns the statement expression text
ExpressionResultCacheService	getExpressionResultCacheServiceSharable()
StatementExtensionSvcContext	getExtensionServicesContext() Returns extension context for statements.
FilterService	getFilterService() Returns the filter service.
InternalEventRouteDest	getInternalEventEngineRouteDest() Returns the internal event router.
MethodResolutionService	getMethodResolutionService() Returns service to look up static and aggregation methods or functions.
MetricReportingServiceSPI	getMetricReportingService() Returns metrics svc.
NamedWindowService	getNamedWindowService() Returns the named window management service.
PatternContextFactory	getPatternContextFactory() Returns the pattern context factory for the statement.
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
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.
StatementAIResourceRegistry	getStatementAgentInstanceRegistry()
StatementEventTypeRef	getStatementEventTypeRef()
java.lang.String	getStatementId() Returns the statement id.
byte[]	getStatementIdBytes()
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
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.
ValueAddEventService	getValueAddEventService() Returns the update event service.
VariableService	getVariableService() Returns variable service.
ViewResolutionService	getViewResolutionService() Returns view resolution svc.
ViewService	getViewService() Returns view svc.
boolean	isStatelessSelect()
boolean	isWritesToTables()
void	setDefaultAgentInstanceLock(StatementAgentInstanceLock defaultAgentInstanceLock)
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
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,
                        byte[] statementIdBytes,
                        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,
                        boolean statelessSelect,
                        ContextControllerFactoryService contextControllerFactoryService,
                        AgentInstanceScriptContext defaultAgentInstanceScriptContext,
                        AggregationServiceFactoryService aggregationServiceFactoryService,
                        boolean writesToTables,
                        java.lang.Object statementUserObject)

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 java.lang.String 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

getExtensionServicesContext

public StatementExtensionSvcContext getExtensionServicesContext()

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

getNamedWindowService

public NamedWindowService getNamedWindowService()

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

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

getStatementIdBytes

public byte[] getStatementIdBytes()

setDefaultAgentInstanceLock

public void setDefaultAgentInstanceLock(StatementAgentInstanceLock defaultAgentInstanceLock)

getPatternSubexpressionPoolSvc

public PatternSubexpressionPoolStmtSvc getPatternSubexpressionPoolSvc()

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