Package com.linkedin.venice.hadoop.task.datawriter

Class AbstractPartitionWriter.VeniceWriterMessage

java.lang.Object

com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter.VeniceWriterMessage

Enclosing class:

AbstractPartitionWriter

public static class AbstractPartitionWriter.VeniceWriterMessage
extends Object

Constructor Summary

Constructors

Constructor	Description
VeniceWriterMessage(byte[] keyBytes, byte[] valueBytes, int valueSchemaId, int rmdVersionId, ByteBuffer rmdPayload, PubSubProducerCallback callback, boolean enableWriteCompute, int derivedValueSchemaId)
VeniceWriterMessage(byte[] keyBytes, byte[] valueBytes, int valueSchemaId, PubSubProducerCallback callback, boolean enableWriteCompute, int derivedValueSchemaId)

Method Summary

Modifier and Type	Method	Description
byte[]	getKeyBytes()
int	getRmdVersionId()
byte[]	getValueBytes()
int	getValueSchemaId()

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceWriterMessage

public VeniceWriterMessage(byte[] keyBytes,
 byte[] valueBytes,
 int valueSchemaId,
 PubSubProducerCallback callback,
 boolean enableWriteCompute,
 int derivedValueSchemaId)

VeniceWriterMessage

public VeniceWriterMessage(byte[] keyBytes,
 byte[] valueBytes,
 int valueSchemaId,
 int rmdVersionId,
 ByteBuffer rmdPayload,
 PubSubProducerCallback callback,
 boolean enableWriteCompute,
 int derivedValueSchemaId)

Method Details

getRmdVersionId

public int getRmdVersionId()

getKeyBytes

public byte[] getKeyBytes()

getValueBytes

public byte[] getValueBytes()

getValueSchemaId

public int getValueSchemaId()