Package com.linkedin.davinci.kafka.consumer

Class WriteComputeResult

java.lang.Object

com.linkedin.davinci.kafka.consumer.WriteComputeResult

public class WriteComputeResult
extends Object

Write compute result wrapper class holding the deserialized updated value and the serialized and potentially compressed updated value bytes.

Constructor Summary

Constructors

Constructor	Description
WriteComputeResult(byte[] updatedValueBytes, org.apache.avro.generic.GenericRecord updatedValue)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	getUpdatedValue()
byte[]	getUpdatedValueBytes()

Methods inherited from class java.lang.Object

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

Constructor Details

WriteComputeResult

public WriteComputeResult(byte[] updatedValueBytes,
 org.apache.avro.generic.GenericRecord updatedValue)

Method Details

getUpdatedValueBytes

@Nullable
public byte[] getUpdatedValueBytes()

getUpdatedValue

@Nullable
public org.apache.avro.generic.GenericRecord getUpdatedValue()