com.espertech.esper.common.internal.epl.variable.core

Interface VariableStateNonConstHandler

public interface VariableStateNonConstHandler

Interface for a plug-in to VariableManagementService to handle variable persistent state.

Method Summary

Modifier and Type	Method and Description
void	addVariable(String deploymentId, String variableName, Variable variable, DataInputOutputSerde serde)
NullableObject<Object>	getHasState(Variable variable, int agentInstanceId) Returns the current variable state plus Boolean.TRUE if there is a current state since the variable may have the value of null; returns Boolean.FALSE and null if there is no current state
DataInputOutputSerde	getVariableSerde(String deploymentId, VariableMetaData metaData)
void	removeState(Variable variable, int agentInstanceId)
void	removeVariable(Variable variable, String deploymentId, Set<Integer> cps)
void	setState(Variable variable, int agentInstanceId, Object newValue) Sets the new variable value

Method Detail

getVariableSerde

DataInputOutputSerde getVariableSerde(String deploymentId,
                                      VariableMetaData metaData)

addVariable

void addVariable(String deploymentId,
                 String variableName,
                 Variable variable,
                 DataInputOutputSerde serde)

getHasState

NullableObject<Object> getHasState(Variable variable,
                                   int agentInstanceId)

Returns the current variable state plus Boolean.TRUE if there is a current state since the variable may have the value of null; returns Boolean.FALSE and null if there is no current state

Parameters:

variable - variable

agentInstanceId - agent instance id

Returns:

indicator whether the variable is known and it's state, or whether it doesn't have state (false)

setState

void setState(Variable variable,
              int agentInstanceId,
              Object newValue)

Sets the new variable value

Parameters:

variable - variable

agentInstanceId - agent instance id

newValue - new variable value, null values allowed

removeState

void removeState(Variable variable,
                 int agentInstanceId)

removeVariable

void removeVariable(Variable variable,
                    String deploymentId,
                    Set<Integer> cps)