com.espertech.esper.core.context.mgr
Class ContextControllerHashFactoryBase
java.lang.Object
com.espertech.esper.core.context.mgr.ContextControllerFactoryBase
com.espertech.esper.core.context.mgr.ContextControllerHashFactoryBase
- All Implemented Interfaces:
- ContextControllerFactory
- Direct Known Subclasses:
- ContextControllerHashFactoryImpl
public abstract class ContextControllerHashFactoryBase
- extends ContextControllerFactoryBase
- implements ContextControllerFactory
Method Summary |
static ContextDetailHashItem |
findHashItemSpec(ContextDetailHash hashSpec,
FilterSpecCompiled filterSpec)
|
static FilterValueSetParam[][] |
getAddendumFilters(FilterSpecCompiled filterSpecCompiled,
int hashCode,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc)
|
static void |
getAddendumFilters(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums,
int hashCode,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc)
|
java.util.Map<java.lang.String,java.lang.Object> |
getContextBuiltinProps()
|
ContextDetail |
getContextDetail()
|
java.util.List<ContextDetailPartitionItem> |
getContextDetailPartitionItems()
|
FilterSpecLookupable |
getFilterLookupable(EventType eventType)
|
ContextDetailHash |
getHashedSpec()
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ContextControllerHashFactoryBase
public ContextControllerHashFactoryBase(ContextControllerFactoryContext factoryContext,
ContextDetailHash hashedSpec,
java.util.List<FilterSpecCompiled> filtersSpecsNestedContexts)
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)
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
keyPayloadToIdentifier
public ContextPartitionIdentifier keyPayloadToIdentifier(java.lang.Object payload)
- Specified by:
keyPayloadToIdentifier
in interface ContextControllerFactory
getAddendumFilters
public static void getAddendumFilters(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums,
int hashCode,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc)
getAddendumFilters
public static FilterValueSetParam[][] getAddendumFilters(FilterSpecCompiled filterSpecCompiled,
int hashCode,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc)
findHashItemSpec
public static ContextDetailHashItem findHashItemSpec(ContextDetailHash hashSpec,
FilterSpecCompiled filterSpec)