Class VariableVersionThreadEntry

java.lang.Object
com.espertech.esper.common.internal.epl.variable.core.VariableVersionThreadEntry

public class VariableVersionThreadEntry extends Object
Thread-specific state in regards to variable versions.
  • Constructor Details

    • VariableVersionThreadEntry

      public VariableVersionThreadEntry(int version, Map<Integer,Pair<Integer,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 Details

    • getVersion

      public Integer getVersion()
      Returns the version visible for a thread.
      Returns:
      version number
    • setVersion

      public void setVersion(Integer version)
      Sets the version visible for a thread.
      Parameters:
      version - version number
    • getUncommitted

      public Map<Integer,Pair<Integer,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(Map<Integer,Pair<Integer,Object>> uncommitted)
      Sets a map of variable number and uncommitted value, or empty map or null if none exist
      Parameters:
      uncommitted - uncommitted values