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

Class IdentityVeniceRecordReader

java.lang.Object

com.linkedin.venice.hadoop.input.recordreader.AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>

com.linkedin.venice.hadoop.input.recordreader.avro.IdentityVeniceRecordReader

public class IdentityVeniceRecordReader
extends AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>

A record reader that returns the input key and value as is.

Method Summary

Modifier and Type	Method	Description
Object	getAvroKey(ByteBuffer keyBytes, ByteBuffer valueBytes)	Return an Avro output key
Object	getAvroValue(ByteBuffer keyBytes, ByteBuffer valueBytes)	return an Avro output value
static IdentityVeniceRecordReader	getInstance()
byte[]	getKeyBytes(ByteBuffer keyBuffer, ByteBuffer valueBuffer)	Return a serialized output key
byte[]	getValueBytes(ByteBuffer keyBuffer, ByteBuffer valueBuffer)	Return a serialized output value

Methods inherited from class com.linkedin.venice.hadoop.input.recordreader.AbstractVeniceRecordReader

configure, getKeySchema, getValueSchema

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static IdentityVeniceRecordReader getInstance()

getAvroKey

public Object getAvroKey(ByteBuffer keyBytes,
 ByteBuffer valueBytes)

Description copied from class: AbstractVeniceRecordReader

Return an Avro output key

Specified by:

getAvroKey in class AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>

getKeyBytes

public byte[] getKeyBytes(ByteBuffer keyBuffer,
 ByteBuffer valueBuffer)

Description copied from class: AbstractVeniceRecordReader

Return a serialized output key

Overrides:

getKeyBytes in class AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>

getAvroValue

public Object getAvroValue(ByteBuffer keyBytes,
 ByteBuffer valueBytes)

Description copied from class: AbstractVeniceRecordReader

return an Avro output value

Specified by:

getAvroValue in class AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>

getValueBytes

public byte[] getValueBytes(ByteBuffer keyBuffer,
 ByteBuffer valueBuffer)

Description copied from class: AbstractVeniceRecordReader

Return a serialized output value

Overrides:

getValueBytes in class AbstractVeniceRecordReader<ByteBuffer,ByteBuffer>