storm.trident.state

Class OpaqueValue<T>

java.lang.Object

storm.trident.state.OpaqueValue<T>

public class OpaqueValue<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
OpaqueValue(Long currTxid, T val)
OpaqueValue(Long currTxid, T val, T prev)

Method Summary

Modifier and Type	Method and Description
T	get(Long batchTxid)
T	getCurr()
Long	getCurrTxid()
T	getPrev()
String	toString()
OpaqueValue<T>	update(Long batchTxid, T newVal)

Methods inherited from class java.lang.Object

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

Constructor Detail

OpaqueValue

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

OpaqueValue

public OpaqueValue(Long currTxid,
                   T val)

Method Detail

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