Package com.linkedin.davinci.kafka.consumer

Class WriteComputeResultWrapper

java.lang.Object

com.linkedin.davinci.kafka.consumer.WriteComputeResultWrapper

public class WriteComputeResultWrapper
extends Object

This result wrapper is for non-Active-Active stores.

Constructor Summary

Constructors

Constructor	Description
WriteComputeResultWrapper(Put newPut, ChunkedValueManifest oldValueManifest, boolean skipProduce)
WriteComputeResultWrapper(Put newPut, ChunkedValueManifest oldValueManifest, boolean skipProduce, Lazy<org.apache.avro.generic.GenericRecord> valueProvider)

Method Summary

Modifier and Type	Method	Description
Put	getNewPut()
ChunkedValueManifest	getOldValueManifest()
Lazy<org.apache.avro.generic.GenericRecord>	getValueProvider()	Return a best-effort value provider with the following behaviors: 1.
boolean	isSkipProduce()

Methods inherited from class java.lang.Object

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

Constructor Details

WriteComputeResultWrapper

public WriteComputeResultWrapper(Put newPut,
 ChunkedValueManifest oldValueManifest,
 boolean skipProduce)

WriteComputeResultWrapper

public WriteComputeResultWrapper(Put newPut,
 ChunkedValueManifest oldValueManifest,
 boolean skipProduce,
 Lazy<org.apache.avro.generic.GenericRecord> valueProvider)

Method Details

getNewPut

public Put getNewPut()

getOldValueManifest

public ChunkedValueManifest getOldValueManifest()

isSkipProduce

public boolean isSkipProduce()

getValueProvider

public Lazy<org.apache.avro.generic.GenericRecord> getValueProvider()

Return a best-effort value provider with the following behaviors: 1. returns the new value provider for PUT and UPDATE. 2. returns the old value for DELETE (null for non-existent key). 3. returns null if the value is not available.