storm.trident.state
Class OpaqueValue<T>
java.lang.Object
storm.trident.state.OpaqueValue<T>
public class OpaqueValue<T>
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
OpaqueValue
public OpaqueValue(java.lang.Long currTxid,
T val,
T prev)
OpaqueValue
public OpaqueValue(java.lang.Long currTxid,
T val)
update
public OpaqueValue<T> update(java.lang.Long batchTxid,
T newVal)
get
public T get(java.lang.Long batchTxid)
getCurr
public T getCurr()
getCurrTxid
public java.lang.Long getCurrTxid()
getPrev
public T getPrev()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object