Package 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	Description
ContextManagerUtil()

Method Summary

Modifier and Type	Method	Description
static MappedEventBean	buildContextProperties(int agentInstanceId, Object[] allPartitionKeys, ContextDefinition contextDefinition, StatementContext statementContextCreate)
static IdentityHashMap<FilterSpecActivatable,FilterValueSetParam[][]>	computeAddendumForStatement(ContextControllerStatementDesc statementDesc, Map<Integer,ContextControllerStatementDesc> statements, 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 Details

ContextManagerUtil

public ContextManagerUtil()

Method Details

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,
 Map<Integer,ContextControllerStatementDesc> statements,
 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)