Package | Description |
---|---|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
Modifier and Type | Field and Description |
---|---|
protected AgentInstance[] |
AgentInstanceArrayIterator.instances |
Modifier and Type | Method and Description |
---|---|
java.util.List<AgentInstance> |
ContextControllerTreeAgentInstanceList.getAgentInstances() |
Modifier and Type | Method and Description |
---|---|
boolean |
AgentInstanceSelector.select(AgentInstance agentInstance) |
Modifier and Type | Method and Description |
---|---|
void |
ContextManagerNested.contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
boolean leaveLocksAcquired,
java.util.List<AgentInstance> agentInstances)
Provides the sub-context that ends.
|
void |
ContextManagerImpl.contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
boolean leaveLocksAcquired,
java.util.List<AgentInstance> agentInstancesCollected) |
void |
ContextControllerLifecycleCallback.contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
boolean leaveLocksAcquired,
java.util.List<AgentInstance> agentInstances) |
Constructor and Description |
---|
AgentInstanceArrayIterator(AgentInstance[] instances) |
AgentInstanceArraySafeIterator(AgentInstance[] instances) |
Constructor and Description |
---|
ContextControllerTreeAgentInstanceList(long filterVersionAfterAllocation,
java.lang.Object initPartitionKey,
java.util.Map<java.lang.String,java.lang.Object> initContextProperties,
java.util.List<AgentInstance> agentInstances,
ContextPartitionState state) |
Modifier and Type | Method and Description |
---|---|
int |
AgentInstanceComparator.compare(AgentInstance ai1,
AgentInstance ai2) |
static void |
StatementAgentInstanceUtil.stopAgentInstanceRemoveResources(AgentInstance agentInstance,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired) |
Modifier and Type | Method and Description |
---|---|
static void |
StatementAgentInstanceUtil.evaluateEventForStatement(EPServicesContext servicesContext,
EventBean theEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.util.List<AgentInstance> agentInstances) |
static void |
StatementAgentInstanceUtil.stopAgentInstances(java.util.List<AgentInstance> agentInstances,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired,
java.util.concurrent.CopyOnWriteArrayList<ContextPartitionStateListener> listenersLazy,
int cpid,
java.lang.String contextName) |