Package com.linkedin.venice.hadoop.input.recordreader

Interface VeniceRecordIterator

All Superinterfaces:
AutoCloseable, Closeable
All Known Implementing Classes:
VeniceAvroFileIterator, VeniceVsonFileIterator
public interface VeniceRecordIterator extends Closeable

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    getCurrentKey()
    Return the current key.
    byte[]
    getCurrentRmd()
    Return the timestamp associated with the current record.
    byte[]
    getCurrentValue()
    Return the current value.
    boolean
    next()
    Proceed to next record, returns false if there is no more records.

    Methods inherited from interface java.io.Closeable

    close

  • Method Details

    • next

      boolean next()
      Proceed to next record, returns false if there is no more records.

    • getCurrentKey

      byte[] getCurrentKey()
      Return the current key. This method should return same value until `next` is called.

    • getCurrentValue

      byte[] getCurrentValue()
      Return the current value. This method should return same value until `next` is called.

    • getCurrentRmd

      byte[] getCurrentRmd()
      Return the timestamp associated with the current record. This method will either return the top level timestamp of the record or rmd of the record or null if a rmd was not specified with the given record