Package | Description |
---|---|
com.espertech.esper.core.context.mgr |
Context management.
|
Modifier and Type | Class and Description |
---|---|
static class |
ContextManagerImpl.ContextNestedHandleImpl |
class |
ContextManagerNestedInstanceHandle |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.Integer,ContextControllerInstanceHandle> |
ContextControllerHash.partitionKeys |
Modifier and Type | Method and Description |
---|---|
ContextControllerInstanceHandle |
ContextManagerNested.contextPartitionInstantiate(java.lang.Integer optionalContextPartitionId,
int subPathId,
java.lang.Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.lang.Object partitionKey,
java.util.Map<java.lang.String,java.lang.Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state,
java.util.function.Supplier<ContextPartitionIdentifier> identifier) |
ContextControllerInstanceHandle |
ContextManagerImpl.contextPartitionInstantiate(java.lang.Integer optionalContextPartitionId,
int subPathId,
java.lang.Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.lang.Object partitionKey,
java.util.Map<java.lang.String,java.lang.Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state,
java.util.function.Supplier<ContextPartitionIdentifier> identifier) |
ContextControllerInstanceHandle |
ContextControllerLifecycleCallback.contextPartitionInstantiate(java.lang.Integer optionalContextPartitionId,
int subpath,
java.lang.Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.lang.Object partitionKey,
java.util.Map<java.lang.String,java.lang.Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state,
java.util.function.Supplier<ContextPartitionIdentifier> identifier) |
ContextControllerInstanceHandle |
ContextControllerPartitionedEntry.getInstanceHandle() |
ContextControllerInstanceHandle |
ContextControllerInitTermInstance.getInstanceHandle() |
Modifier and Type | Method and Description |
---|---|
void |
ContextManagerNested.contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
ContextController originator,
ContextControllerState controllerState,
int exportedCPOrPathId,
ContextInternalFilterAddendum filterAddendum,
AgentInstanceSelector agentInstanceSelector,
byte[] payload,
boolean isRecoveringResilient) |
void |
ContextManagerImpl.contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
ContextController originator,
ContextControllerState controllerState,
int exportedCPOrPathId,
ContextInternalFilterAddendum filterAddendum,
AgentInstanceSelector agentInstanceSelector,
byte[] payload,
boolean isRecoveringResilient) |
void |
ContextControllerLifecycleCallback.contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
ContextController originator,
ContextControllerState controllerState,
int exportedCPOrPathId,
ContextInternalFilterAddendum filterAddendum,
AgentInstanceSelector agentInstanceSelector,
byte[] payload,
boolean isRecoveringResilient) |
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) |
void |
ContextPartitionVisitorStateWithPath.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
java.lang.Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorState.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
java.lang.Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorAgentInstanceIdWPath.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
java.lang.Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorAgentInstanceId.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
java.lang.Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitor.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
java.lang.Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
Constructor and Description |
---|
ContextControllerInitTermInstance(ContextControllerInstanceHandle instanceHandle,
java.util.Map<java.lang.String,java.lang.Object> startProperties,
long startTime,
java.lang.Long endTime,
int subPathId) |
ContextControllerPartitionedEntry(ContextControllerInstanceHandle instanceHandle,
ContextControllerCondition optionalTermination) |