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

Class VeniceVsonFileIterator

java.lang.Object

com.linkedin.venice.hadoop.input.recordreader.vson.VeniceVsonFileIterator

All Implemented Interfaces:

VeniceRecordIterator, Closeable, AutoCloseable

public class VeniceVsonFileIterator
extends Object
implements VeniceRecordIterator

Constructor Summary

Constructors

Constructor	Description
VeniceVsonFileIterator(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hdfsPath, VeniceVsonRecordReader recordReader)

Method Summary

Modifier and Type	Method	Description
void	close()
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

VeniceVsonFileIterator

public VeniceVsonFileIterator(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path hdfsPath,
 VeniceVsonRecordReader recordReader)

Method Details

getCurrentKey

public byte[] getCurrentKey()

Description copied from interface: VeniceRecordIterator

Return the current key. This method should return same value until `next` is called.

Specified by:

getCurrentKey in interface VeniceRecordIterator

getCurrentValue

public byte[] getCurrentValue()

Description copied from interface: VeniceRecordIterator

Return the current value. This method should return same value until `next` is called.

Specified by:

getCurrentValue in interface VeniceRecordIterator

getTimeStamp

public long getTimeStamp()

Description copied from interface: VeniceRecordIterator

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

Specified by:

getTimeStamp in interface VeniceRecordIterator

Returns:

next

public boolean next()

Description copied from interface: VeniceRecordIterator

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

Specified by:

next in interface VeniceRecordIterator

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException