com.espertech.esper.epl.variable

Class VariableVersionThreadEntry

java.lang.Object

com.espertech.esper.epl.variable.VariableVersionThreadEntry

public class VariableVersionThreadEntry
extends java.lang.Object

Thread-specific state in regards to variable versions.

Constructor Summary

Constructors

Constructor and Description
VariableVersionThreadEntry(int version, java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>> uncommitted) Ctor.

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>>	getUncommitted() Returns a map of variable number and uncommitted value, or empty map or null if none exist
java.lang.Integer	getVersion() Returns the version visible for a thread.
void	setUncommitted(java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>> uncommitted) Sets a map of variable number and uncommitted value, or empty map or null if none exist
void	setVersion(java.lang.Integer version) Sets the version visible for a thread.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VariableVersionThreadEntry

public VariableVersionThreadEntry(int version,
                                  java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>> uncommitted)

Ctor.

Parameters:

version - current version number of the variables visible to thread

uncommitted - the uncommitted values of variables for the thread, if any

Method Detail

getVersion

public java.lang.Integer getVersion()

Returns the version visible for a thread.

Returns:

version number

setVersion

public void setVersion(java.lang.Integer version)

Sets the version visible for a thread.

Parameters:

version - version number

getUncommitted

public java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>> getUncommitted()

Returns a map of variable number and uncommitted value, or empty map or null if none exist

Returns:

uncommitted values

setUncommitted

public void setUncommitted(java.util.Map<java.lang.Integer,Pair<java.lang.Integer,java.lang.Object>> uncommitted)

Sets a map of variable number and uncommitted value, or empty map or null if none exist

Parameters:

uncommitted - uncommitted values