Package com.linkedin.venice.samza

Class VeniceObjectWithTimestamp

java.lang.Object
com.linkedin.venice.samza.VeniceObjectWithTimestamp
public class VeniceObjectWithTimestamp extends 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 to VeniceSystemProducer. Specifically, for the users who are using VeniceSystemProducer.send(String, OutgoingMessageEnvelope), the wrapper will replace OutgoingMessageEnvelope.message.

  • Constructor Details

    • VeniceObjectWithTimestamp

      public VeniceObjectWithTimestamp(Object object, long timestamp)

  • Method Details

    • getObject

      public Object getObject()

    • getTimestamp

      public long getTimestamp()