Package com.linkedin.davinci.kafka.consumer

Class MergeConflictResultWrapper

java.lang.Object

com.linkedin.davinci.kafka.consumer.MergeConflictResultWrapper

public class MergeConflictResultWrapper
extends Object

This wrapper is used to keep the context after handling Active/Active messages.

Constructor Summary

Constructors

Constructor	Description
MergeConflictResultWrapper(MergeConflictResult mergeConflictResult, Lazy<ByteBufferValueRecord<ByteBuffer>> oldValueProvider, Lazy<ByteBuffer> oldValueByteBufferProvider, RmdWithValueSchemaId oldRmdWithValueSchemaId, ChunkedValueManifestContainer oldValueManifestContainer, ByteBuffer updatedValueBytes, ByteBuffer updatedRmdBytes)

Method Summary

Modifier and Type	Method	Description
MergeConflictResult	getMergeConflictResult()
RmdWithValueSchemaId	getOldRmdWithValueSchemaId()
Lazy<ByteBuffer>	getOldValueByteBufferProvider()
ChunkedValueManifestContainer	getOldValueManifestContainer()
Lazy<ByteBufferValueRecord<ByteBuffer>>	getOldValueProvider()
ByteBuffer	getUpdatedRmdBytes()
ByteBuffer	getUpdatedValueBytes()

Methods inherited from class java.lang.Object

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

Constructor Details

MergeConflictResultWrapper

public MergeConflictResultWrapper(MergeConflictResult mergeConflictResult,
 Lazy<ByteBufferValueRecord<ByteBuffer>> oldValueProvider,
 Lazy<ByteBuffer> oldValueByteBufferProvider,
 RmdWithValueSchemaId oldRmdWithValueSchemaId,
 ChunkedValueManifestContainer oldValueManifestContainer,
 ByteBuffer updatedValueBytes,
 ByteBuffer updatedRmdBytes)

Method Details

getMergeConflictResult

public MergeConflictResult getMergeConflictResult()

getOldValueByteBufferProvider

public Lazy<ByteBuffer> getOldValueByteBufferProvider()

getOldRmdWithValueSchemaId

public RmdWithValueSchemaId getOldRmdWithValueSchemaId()

getOldValueManifestContainer

public ChunkedValueManifestContainer getOldValueManifestContainer()

getOldValueProvider

public Lazy<ByteBufferValueRecord<ByteBuffer>> getOldValueProvider()

getUpdatedValueBytes

public ByteBuffer getUpdatedValueBytes()

getUpdatedRmdBytes

public ByteBuffer getUpdatedRmdBytes()