com.espertech.esper.core.context.mgr
Class ContextControllerInitTermFactory

java.lang.Object
  com.espertech.esper.core.context.mgr.ContextControllerFactoryBase
      com.espertech.esper.core.context.mgr.ContextControllerInitTermFactory

All Implemented Interfaces:

ContextControllerFactory

public class ContextControllerInitTermFactory
extends ContextControllerFactoryBase
implements ContextControllerFactory

Field Summary

Fields inherited from class com.espertech.esper.core.context.mgr.ContextControllerFactoryBase

factoryContext

Constructor Summary

ContextControllerInitTermFactory(ContextControllerFactoryContext factoryContext, ContextDetailInitiatedTerminated detail, ContextStateCache stateCache)

Method Summary

ScheduleSlot	allocateSlot()
ContextController	createNoCallback(int pathId, ContextControllerLifecycleCallback callback)
ContextStatePathValueBinding	getBinding()
java.util.Map<java.lang.String,java.lang.Object>	getContextBuiltinProps()
ContextDetailInitiatedTerminated	getContextDetail()
java.util.List<ContextDetailPartitionItem>	getContextDetailPartitionItems()
EPStatementHandle	getEpStatementHandle()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
MatchedEventMapMeta	getMatchedEventMapMeta()
SchedulingService	getSchedulingService()
ContextStateCache	getStateCache()
StatementAIResourceRegistryFactory	getStatementAIResourceRegistryFactory()
StatementContext	getStatementContext()
TimeProvider	getTimeProvider()
boolean	isSingleInstanceContext()
ContextPartitionIdentifier	keyPayloadToIdentifier(java.lang.Object payload)
void	populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum, ContextControllerStatementDesc statement, java.lang.Object key, int contextId)
void	validateFactory()
ContextControllerStatementCtxCache	validateStatement(ContextControllerStatementBase statement)

Methods inherited from class com.espertech.esper.core.context.mgr.ContextControllerFactoryBase

getFactoryContext

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.core.context.mgr.ContextControllerFactory

getFactoryContext

Constructor Detail

ContextControllerInitTermFactory

public ContextControllerInitTermFactory(ContextControllerFactoryContext factoryContext,
                                        ContextDetailInitiatedTerminated detail,
                                        ContextStateCache stateCache)

Method Detail

validateFactory

public void validateFactory()
                     throws ExprValidationException

Specified by:

validateFactory in interface ContextControllerFactory

Throws:

ExprValidationException

getStateCache

public ContextStateCache getStateCache()

Specified by:

getStateCache in interface ContextControllerFactory

getBinding

public ContextStatePathValueBinding getBinding()

getContextBuiltinProps

public java.util.Map<java.lang.String,java.lang.Object> getContextBuiltinProps()

Specified by:

getContextBuiltinProps in interface ContextControllerFactory

getMatchedEventMapMeta

public MatchedEventMapMeta getMatchedEventMapMeta()

validateStatement

public ContextControllerStatementCtxCache validateStatement(ContextControllerStatementBase statement)

Specified by:

validateStatement in interface ContextControllerFactory

createNoCallback

public ContextController createNoCallback(int pathId,
                                          ContextControllerLifecycleCallback callback)

Specified by:

createNoCallback in interface ContextControllerFactory

populateFilterAddendums

public void populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
                                    ContextControllerStatementDesc statement,
                                    java.lang.Object key,
                                    int contextId)

Specified by:

populateFilterAddendums in interface ContextControllerFactory

getFilterLookupable

public FilterSpecLookupable getFilterLookupable(EventType eventType)

Specified by:

getFilterLookupable in interface ContextControllerFactory

getContextDetail

public ContextDetailInitiatedTerminated getContextDetail()

Specified by:

getContextDetail in interface ContextControllerFactory

getContextDetailPartitionItems

public java.util.List<ContextDetailPartitionItem> getContextDetailPartitionItems()

Specified by:

getContextDetailPartitionItems in interface ContextControllerFactory

getStatementAIResourceRegistryFactory

public StatementAIResourceRegistryFactory getStatementAIResourceRegistryFactory()

Specified by:

getStatementAIResourceRegistryFactory in interface ContextControllerFactory

isSingleInstanceContext

public boolean isSingleInstanceContext()

Specified by:

isSingleInstanceContext in interface ContextControllerFactory

allocateSlot

public ScheduleSlot allocateSlot()

getTimeProvider

public TimeProvider getTimeProvider()

getSchedulingService

public SchedulingService getSchedulingService()

getEpStatementHandle

public EPStatementHandle getEpStatementHandle()

getStatementContext

public StatementContext getStatementContext()

keyPayloadToIdentifier

public ContextPartitionIdentifier keyPayloadToIdentifier(java.lang.Object payload)

Specified by:

keyPayloadToIdentifier in interface ContextControllerFactory