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 HashMap<Object,ContextControllerInstanceHandle> |
ContextControllerPartitioned.partitionKeys |
protected Map<Integer,ContextControllerInstanceHandle> |
ContextControllerHash.partitionKeys |
Modifier and Type | Method and Description |
---|---|
ContextControllerInstanceHandle |
ContextManagerNested.contextPartitionInstantiate(Integer optionalContextPartitionId,
int subPathId,
Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
Map<String,Object> optionalTriggeringPattern,
Object partitionKey,
Map<String,Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state) |
ContextControllerInstanceHandle |
ContextManagerImpl.contextPartitionInstantiate(Integer optionalContextPartitionId,
int subPathId,
Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
Map<String,Object> optionalTriggeringPattern,
Object partitionKey,
Map<String,Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state) |
ContextControllerInstanceHandle |
ContextControllerLifecycleCallback.contextPartitionInstantiate(Integer optionalContextPartitionId,
int subpath,
Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
Map<String,Object> optionalTriggeringPattern,
Object partitionKey,
Map<String,Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state) |
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,
Map<String,Object> terminationProperties,
boolean leaveLocksAcquired,
List<AgentInstance> agentInstances)
Provides the sub-context that ends.
|
void |
ContextManagerImpl.contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
Map<String,Object> terminationProperties,
boolean leaveLocksAcquired,
List<AgentInstance> agentInstancesCollected) |
void |
ContextControllerLifecycleCallback.contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
Map<String,Object> terminationProperties,
boolean leaveLocksAcquired,
List<AgentInstance> agentInstances) |
void |
ContextPartitionVisitorStateWithPath.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorState.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorAgentInstanceIdWPath.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitorAgentInstanceId.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
void |
ContextPartitionVisitor.visit(int nestingLevel,
int pathId,
ContextStatePathValueBinding binding,
Object payload,
ContextController contextController,
ContextControllerInstanceHandle instanceHandle) |
Constructor and Description |
---|
ContextControllerInitTermInstance(ContextControllerInstanceHandle instanceHandle,
Map<String,Object> startProperties,
long startTime,
Long endTime,
int subPathId) |