com.espertech.esper.core.context.mgr

Class ContextControllerInitTermFactoryBase

java.lang.Object

com.espertech.esper.core.context.mgr.ContextControllerFactoryBase

com.espertech.esper.core.context.mgr.ContextControllerInitTermFactoryBase

All Implemented Interfaces:

ContextControllerFactory

Direct Known Subclasses:

ContextControllerInitTermFactoryImpl

public abstract class ContextControllerInitTermFactoryBase
extends ContextControllerFactoryBase
implements ContextControllerFactory

Field Summary

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

factoryContext

Constructor Summary

Constructors

Constructor and Description
ContextControllerInitTermFactoryBase(ContextControllerFactoryContext factoryContext, ContextDetailInitiatedTerminated detail)

Method Summary

Modifier and Type	Method and Description
long	allocateSlot()
Map<String,Object>	getContextBuiltinProps()
ContextDetailInitiatedTerminated	getContextDetail()
List<ContextDetailPartitionItem>	getContextDetailPartitionItems()
EPStatementHandle	getEpStatementHandle()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
MatchedEventMapMeta	getMatchedEventMapMeta()
SchedulingService	getSchedulingService()
StatementAIResourceRegistryFactory	getStatementAIResourceRegistryFactory()
StatementContext	getStatementContext()
TimeProvider	getTimeProvider()
boolean	isSingleInstanceContext()
ContextPartitionIdentifier	keyPayloadToIdentifier(Object payload)
void	populateFilterAddendums(IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum, ContextControllerStatementDesc statement, Object key, int contextId)
void	validateFactory()
ContextControllerStatementCtxCache	validateStatement(ContextControllerStatementBase statement)

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

getFactoryContext, getStateCache

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

createNoCallback, getFactoryContext, getStateCache

Constructor Detail

ContextControllerInitTermFactoryBase

public ContextControllerInitTermFactoryBase(ContextControllerFactoryContext factoryContext,
                                            ContextDetailInitiatedTerminated detail)

Method Detail

validateFactory

public void validateFactory()
                     throws ExprValidationException

Specified by:

validateFactory in interface ContextControllerFactory

Throws:

ExprValidationException

getContextBuiltinProps

public Map<String,Object> getContextBuiltinProps()

Specified by:

getContextBuiltinProps in interface ContextControllerFactory

getMatchedEventMapMeta

public MatchedEventMapMeta getMatchedEventMapMeta()

validateStatement

public ContextControllerStatementCtxCache validateStatement(ContextControllerStatementBase statement)

Specified by:

validateStatement in interface ContextControllerFactory

populateFilterAddendums

public void populateFilterAddendums(IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
                                    ContextControllerStatementDesc statement,
                                    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 List<ContextDetailPartitionItem> getContextDetailPartitionItems()

Specified by:

getContextDetailPartitionItems in interface ContextControllerFactory

isSingleInstanceContext

public boolean isSingleInstanceContext()

Specified by:

isSingleInstanceContext in interface ContextControllerFactory

allocateSlot

public long allocateSlot()

getTimeProvider

public TimeProvider getTimeProvider()

getSchedulingService

public SchedulingService getSchedulingService()

getEpStatementHandle

public EPStatementHandle getEpStatementHandle()

getStatementContext

public StatementContext getStatementContext()

keyPayloadToIdentifier

public ContextPartitionIdentifier keyPayloadToIdentifier(Object payload)

Specified by:

keyPayloadToIdentifier in interface ContextControllerFactory

getStatementAIResourceRegistryFactory

public StatementAIResourceRegistryFactory getStatementAIResourceRegistryFactory()

Specified by:

getStatementAIResourceRegistryFactory in interface ContextControllerFactory