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

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

All Implemented Interfaces:

ContextControllerFactory

public class ContextControllerHashFactory
extends ContextControllerFactoryBase
implements ContextControllerFactory

Nested Class Summary

static class

ContextControllerHashFactory.HashFunctionEnum

Field Summary

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

factoryContext

Constructor Summary

ContextControllerHashFactory(ContextControllerFactoryContext factoryContext, ContextDetailHash hashedSpec, java.util.List<FilterSpecCompiled> filtersSpecsNestedContexts, ContextStateCache stateCache)

Method Summary

ContextController	createNoCallback(int pathId, ContextControllerLifecycleCallback callback)
static ContextDetailHashItem	findHashItemSpec(ContextDetailHash hashSpec, FilterSpecCompiled filterSpec)
ContextStatePathValueBinding	getBinding()
java.util.Map<java.lang.String,java.lang.Object>	getContextBuiltinProps()
ContextDetail	getContextDetail()
java.util.List<ContextDetailPartitionItem>	getContextDetailPartitionItems()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
ContextDetailHash	getHashedSpec()
ContextStateCache	getStateCache()
StatementAIResourceRegistryFactory	getStatementAIResourceRegistryFactory()
boolean	hasFiltersSpecsNestedContexts()
boolean	isSingleInstanceContext()
ContextPartitionIdentifier	keyPayloadToIdentifier(java.lang.Object payload)
void	populateContextInternalFilterAddendums(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

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

ContextControllerHashFactory

public ContextControllerHashFactory(ContextControllerFactoryContext factoryContext,
                                    ContextDetailHash hashedSpec,
                                    java.util.List<FilterSpecCompiled> filtersSpecsNestedContexts,
                                    ContextStateCache stateCache)

Method Detail

hasFiltersSpecsNestedContexts

public boolean hasFiltersSpecsNestedContexts()

getStateCache

public ContextStateCache getStateCache()

Specified by:

getStateCache in interface ContextControllerFactory

getBinding

public ContextStatePathValueBinding getBinding()

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)

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

getHashedSpec

public ContextDetailHash getHashedSpec()

getContextBuiltinProps

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

Specified by:

getContextBuiltinProps in interface ContextControllerFactory

createNoCallback

public ContextController createNoCallback(int pathId,
                                          ContextControllerLifecycleCallback callback)

Specified by:

createNoCallback in interface ContextControllerFactory

keyPayloadToIdentifier

public ContextPartitionIdentifier keyPayloadToIdentifier(java.lang.Object payload)

Specified by:

keyPayloadToIdentifier in interface ContextControllerFactory

findHashItemSpec

public static ContextDetailHashItem findHashItemSpec(ContextDetailHash hashSpec,
                                                     FilterSpecCompiled filterSpec)