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

Constructor Summary

Constructors

Constructor and Description
ContextControllerPartitionedUtil()

Method Summary

Modifier and Type	Method and Description
static FilterValueSetParam[][]	getAddendumFilters(java.lang.Object keyValue, FilterSpecCompiled filtersSpec, ContextDetailPartitioned segmentedSpec, boolean includePartition, 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

Constructor Detail

ContextControllerPartitionedUtil

public ContextControllerPartitionedUtil()

Method Detail

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,
                                                         boolean includePartition,
                                                         StatementSpecCompiled optionalStatementSpecCompiled)