com.espertech.esper.common.internal.context.mgr

Class ContextManagerUtil

java.lang.Object

com.espertech.esper.common.internal.context.mgr.ContextManagerUtil

public class ContextManagerUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ContextManagerUtil()

Method Summary

Modifier and Type	Method and Description
static MappedEventBean	buildContextProperties(int agentInstanceId, Object[] allPartitionKeys, ContextDefinition contextDefinition, StatementContext statementContextCreate)
static IdentityHashMap<FilterSpecActivatable,FilterValueSetParam[][]>	computeAddendumForStatement(ContextControllerStatementDesc statementDesc, ContextControllerFactory[] controllerFactories, Object[] allPartitionKeys, AgentInstanceContext agentInstanceContextCreate)
static FilterValueSetParam[][]	computeAddendumNonStmt(Object[] partitionKeys, FilterSpecActivatable filterCallback, ContextManagerRealization realization)
static AgentInstance	getAgentInstance(StatementContext statementContext, int agentInstanceId)
static List<AgentInstance>	getAgentInstances(ContextControllerStatementDesc statement, Collection<Integer> agentInstanceIds)
static List<AgentInstance>	getAgentInstancesFiltered(ContextControllerStatementDesc statement, Collection<Integer> agentInstanceIds, Function<AgentInstance,Boolean> filter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ContextManagerUtil

public ContextManagerUtil()

Method Detail

getAgentInstances

public static List<AgentInstance> getAgentInstances(ContextControllerStatementDesc statement,
                                                    Collection<Integer> agentInstanceIds)

getAgentInstance

public static AgentInstance getAgentInstance(StatementContext statementContext,
                                             int agentInstanceId)

getAgentInstancesFiltered

public static List<AgentInstance> getAgentInstancesFiltered(ContextControllerStatementDesc statement,
                                                            Collection<Integer> agentInstanceIds,
                                                            Function<AgentInstance,Boolean> filter)

computeAddendumForStatement

public static IdentityHashMap<FilterSpecActivatable,FilterValueSetParam[][]> computeAddendumForStatement(ContextControllerStatementDesc statementDesc,
                                                                                                         ContextControllerFactory[] controllerFactories,
                                                                                                         Object[] allPartitionKeys,
                                                                                                         AgentInstanceContext agentInstanceContextCreate)

computeAddendumNonStmt

public static FilterValueSetParam[][] computeAddendumNonStmt(Object[] partitionKeys,
                                                             FilterSpecActivatable filterCallback,
                                                             ContextManagerRealization realization)

buildContextProperties

public static MappedEventBean buildContextProperties(int agentInstanceId,
                                                     Object[] allPartitionKeys,
                                                     ContextDefinition contextDefinition,
                                                     StatementContext statementContextCreate)