Package com.linkedin.venice.samza
Class VeniceObjectWithTimestamp
- java.lang.Object
-
- com.linkedin.venice.samza.VeniceObjectWithTimestamp
-
public class VeniceObjectWithTimestamp extends java.lang.Object
This class defines a wrapper object to wrap up the actual object and the corresponding update timestamp. For the users who need to specify the logical update timestamp, you will need to wrap up your update and the corresponding update timestamp and pass it toVeniceSystemProducer
. Specifically, for the users who are usingVeniceSystemProducer.send(String, OutgoingMessageEnvelope)
, the wrapper will replaceOutgoingMessageEnvelope.message
.
-
-
Constructor Summary
Constructors Constructor Description VeniceObjectWithTimestamp(java.lang.Object object, long timestamp)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
getObject()
long
getTimestamp()
-