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 java.lang.Object

Constructor Summary

Constructors

Constructor	Description
VeniceWriterMessage(byte[] keyBytes, byte[] valueBytes, int valueSchemaId, int rmdVersionId, java.nio.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 Detail

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,
                           java.nio.ByteBuffer rmdPayload,
                           PubSubProducerCallback callback,
                           boolean enableWriteCompute,
                           int derivedValueSchemaId)

Method Detail

getRmdVersionId

public int getRmdVersionId()

getKeyBytes

public byte[] getKeyBytes()

getValueBytes

public byte[] getValueBytes()

getValueSchemaId

public int getValueSchemaId()