Package com.linkedin.venice.samza

package com.linkedin.venice.samza
  • Class
    Description
    SamzaExitMode
    Various methods for stopping/exiting a Samza task.
    SerializedRecord
    A value object holding the Avro-serialized key and value bytes along with the resolved schema IDs and logical timestamp needed to write a record to Venice.
    VeniceObjectWithTimestamp
    This class defines a wrapper object to wrap up the actual object and the corresponding update timestamp.
    VeniceSystemFactory
    Samza jobs talk to either parent or child controller depending on the aggregate mode config.
    VeniceSystemProducer
    VeniceSystemProducer defines the interfaces for Samza jobs to send data to Venice stores.