com.espertech.esper.core.context.mgr

Class ContextControllerPartitionedFactoryBase

java.lang.Object

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

com.espertech.esper.core.context.mgr.ContextControllerPartitionedFactoryBase

All Implemented Interfaces:

ContextControllerFactory

Direct Known Subclasses:

ContextControllerPartitionedFactoryImpl

public abstract class ContextControllerPartitionedFactoryBase
extends ContextControllerFactoryBase
implements ContextControllerFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ContextDetailPartitioned	segmentedSpec

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

factoryContext

Constructor Summary

Constructors

Constructor and Description
ContextControllerPartitionedFactoryBase(ContextControllerFactoryContext factoryContext, ContextDetailPartitioned segmentedSpec, java.util.List<FilterSpecCompiled> filtersSpecsNestedContexts)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	getContextBuiltinProps()
ContextDetail	getContextDetail()
java.util.List<ContextDetailPartitionItem>	getContextDetailPartitionItems()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
ContextDetailPartitioned	getSegmentedSpec()
StatementAIResourceRegistryFactory	getStatementAIResourceRegistryFactory()
MatchedEventMapMeta	getTermConditionMatchEventMap()
boolean	hasFiltersSpecsNestedContexts()
boolean	isSingleInstanceContext()
ContextPartitionIdentifier	keyPayloadToIdentifier(java.lang.Object payload)
void	populateContextInternalFilterAddendums(ContextInternalFilterAddendum filterAddendum, java.lang.Object key)
void	populateContextInternalFilterAddendumsTermination(ContextInternalFilterAddendum filterAddendum, java.lang.Object key)
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, 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

Field Detail

segmentedSpec

protected final ContextDetailPartitioned segmentedSpec

Constructor Detail

ContextControllerPartitionedFactoryBase

public ContextControllerPartitionedFactoryBase(ContextControllerFactoryContext factoryContext,
                                               ContextDetailPartitioned segmentedSpec,
                                               java.util.List<FilterSpecCompiled> filtersSpecsNestedContexts)

Method Detail

hasFiltersSpecsNestedContexts

public boolean hasFiltersSpecsNestedContexts()

validateFactory

public void validateFactory()
                     throws ExprValidationException

Specified by:

validateFactory in interface ContextControllerFactory

Throws:

ExprValidationException

validateStatement

public ContextControllerStatementCtxCache validateStatement(ContextControllerStatementBase statement)
                                                     throws ExprValidationException

Specified by:

validateStatement in interface ContextControllerFactory

Throws:

ExprValidationException

populateFilterAddendums

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

Specified by:

populateFilterAddendums in interface ContextControllerFactory

populateContextInternalFilterAddendums

public void populateContextInternalFilterAddendums(ContextInternalFilterAddendum filterAddendum,
                                                   java.lang.Object key)

populateContextInternalFilterAddendumsTermination

public void populateContextInternalFilterAddendumsTermination(ContextInternalFilterAddendum filterAddendum,
                                                              java.lang.Object key)

getFilterLookupable

public FilterSpecLookupable getFilterLookupable(EventType eventType)

Specified by:

getFilterLookupable in interface ContextControllerFactory

isSingleInstanceContext

public boolean isSingleInstanceContext()

Specified by:

isSingleInstanceContext in interface ContextControllerFactory

getStatementAIResourceRegistryFactory

public StatementAIResourceRegistryFactory getStatementAIResourceRegistryFactory()

Specified by:

getStatementAIResourceRegistryFactory in interface ContextControllerFactory

getContextDetailPartitionItems

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

Specified by:

getContextDetailPartitionItems in interface ContextControllerFactory

getContextDetail

public ContextDetail getContextDetail()

Specified by:

getContextDetail in interface ContextControllerFactory

getSegmentedSpec

public ContextDetailPartitioned getSegmentedSpec()

getTermConditionMatchEventMap

public MatchedEventMapMeta getTermConditionMatchEventMap()

getContextBuiltinProps

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

Specified by:

getContextBuiltinProps in interface ContextControllerFactory

keyPayloadToIdentifier

public ContextPartitionIdentifier keyPayloadToIdentifier(java.lang.Object payload)

Specified by:

keyPayloadToIdentifier in interface ContextControllerFactory