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[]
    getCurrentValue()
    Return the current value.
    long
    getTimeStamp()
    Return the timestamp associated with the current record.
    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.

    • getTimeStamp

      long getTimeStamp()
      Return the timestamp associated with the current record. This method will either return the timestamp of the record or -1L if a timestamp was not specified with the given record
      Returns: