Class OpaqueValue<T>

java.lang.Object
org.apache.storm.trident.state.OpaqueValue<T>

public class OpaqueValue<T> extends Object
  • Constructor Details

    • OpaqueValue

      public OpaqueValue(Long currTxid, T val, T prev)
    • OpaqueValue

      public OpaqueValue(Long currTxid, T val)
  • Method Details

    • update

      public OpaqueValue<T> update(Long batchTxid, T newVal)
    • get

      public T get(Long batchTxid)
    • getCurr

      public T getCurr()
    • getCurrTxid

      public Long getCurrTxid()
    • getPrev

      public T getPrev()
    • toString

      public String toString()
      Overrides:
      toString in class Object