Package | Description |
---|---|
com.espertech.esper.client.context |
Context partition selection and descriptors.
|
com.espertech.esper.core.context.mgr |
Context management.
|
Modifier and Type | Method and Description |
---|---|
ContextPartitionState |
ContextPartitionDescriptor.getState()
Returns context partition state.
|
static ContextPartitionState |
ContextPartitionState.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ContextPartitionState[] |
ContextPartitionState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
ContextPartitionDescriptor.setState(ContextPartitionState state)
Convenience method for updating context partition state, does not affect actual context partition state.
|
Constructor and Description |
---|
ContextPartitionDescriptor(int agentInstanceId,
ContextPartitionIdentifier identifier,
ContextPartitionState state)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ContextPartitionState |
ContextStatePathValue.getState() |
ContextPartitionState |
ContextControllerTreeAgentInstanceList.getState() |
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) |
void |
ContextStatePathValue.setState(ContextPartitionState state) |
void |
ContextControllerTreeAgentInstanceList.setState(ContextPartitionState state) |
protected static void |
ContextManagerImpl.setState(java.util.Map<java.lang.Integer,ContextPartitionDescriptor> original,
ContextPartitionState state) |
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) |
ContextStatePathValue(java.lang.Integer optionalContextPartitionId,
byte[] blob,
ContextPartitionState state) |