com.espertech.esper.core.context.mgr
Class ContextControllerPartitionedUtil
java.lang.Object
com.espertech.esper.core.context.mgr.ContextControllerPartitionedUtil
public class ContextControllerPartitionedUtil
- extends java.lang.Object
Method Summary |
static FilterValueSetParam[][] |
getAddendumFilters(java.lang.Object keyValue,
FilterSpecCompiled filtersSpec,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled)
|
static void |
populateAddendumFilters(java.lang.Object keyValue,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums)
|
protected static java.lang.Class[] |
validateContextDesc(java.lang.String contextName,
ContextDetailPartitioned segmentedSpec)
|
protected static void |
validateStatementForContext(java.lang.String contextName,
ContextControllerStatementBase statement,
StatementSpecCompiledAnalyzerResult streamAnalysis,
java.util.Collection<EventType> itemEventTypes,
NamedWindowMgmtService namedWindowMgmtService)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ContextControllerPartitionedUtil
public ContextControllerPartitionedUtil()
validateContextDesc
protected static java.lang.Class[] validateContextDesc(java.lang.String contextName,
ContextDetailPartitioned segmentedSpec)
throws ExprValidationException
- Throws:
ExprValidationException
validateStatementForContext
protected static void validateStatementForContext(java.lang.String contextName,
ContextControllerStatementBase statement,
StatementSpecCompiledAnalyzerResult streamAnalysis,
java.util.Collection<EventType> itemEventTypes,
NamedWindowMgmtService namedWindowMgmtService)
throws ExprValidationException
- Throws:
ExprValidationException
populateAddendumFilters
public static void populateAddendumFilters(java.lang.Object keyValue,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums)
getAddendumFilters
public static FilterValueSetParam[][] getAddendumFilters(java.lang.Object keyValue,
FilterSpecCompiled filtersSpec,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled)