Package com.linkedin.davinci.kafka.consumer

Class MergeConflictResultWrapper

java.lang.Object

com.linkedin.davinci.kafka.consumer.MergeConflictResultWrapper

public class MergeConflictResultWrapper
extends java.lang.Object

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeConflictResultWrapper

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

Method Detail

getMergeConflictResult

public MergeConflictResult getMergeConflictResult()

getOldValueByteBufferProvider

public Lazy<java.nio.ByteBuffer> getOldValueByteBufferProvider()

getOldRmdWithValueSchemaId

public RmdWithValueSchemaId getOldRmdWithValueSchemaId()

getOldValueManifestContainer

public ChunkedValueManifestContainer getOldValueManifestContainer()

getOldValueProvider

public Lazy<ByteBufferValueRecord<java.nio.ByteBuffer>> getOldValueProvider()

getUpdatedValueBytes

public java.nio.ByteBuffer getUpdatedValueBytes()

getUpdatedRmdBytes

public java.nio.ByteBuffer getUpdatedRmdBytes()