Package com.linkedin.davinci.kafka.consumer

Class StoreWriteComputeProcessor

java.lang.Object

com.linkedin.davinci.kafka.consumer.StoreWriteComputeProcessor

public class StoreWriteComputeProcessor
extends java.lang.Object

This class handles Write Compute operations related to a specific store.

Constructor Summary

Constructors

Constructor	Description
StoreWriteComputeProcessor(java.lang.String storeName, ReadOnlySchemaRepository schemaRepo, MergeRecordHelper mergeRecordHelper, boolean fastAvroEnabled)

Method Summary

Modifier and Type	Method	Description
byte[]	applyWriteCompute(org.apache.avro.generic.GenericRecord currValue, int writerValueSchemaId, int readerValueSchemaId, java.nio.ByteBuffer writeComputeBytes, int writerUpdateProtocolVersion, int readerUpdateProtocolVersion)	Apply Update operation on the current value record.

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreWriteComputeProcessor

public StoreWriteComputeProcessor(@Nonnull
                                  java.lang.String storeName,
                                  @Nonnull
                                  ReadOnlySchemaRepository schemaRepo,
                                  MergeRecordHelper mergeRecordHelper,
                                  boolean fastAvroEnabled)

Method Detail

applyWriteCompute

public byte[] applyWriteCompute(org.apache.avro.generic.GenericRecord currValue,
                                int writerValueSchemaId,
                                int readerValueSchemaId,
                                java.nio.ByteBuffer writeComputeBytes,
                                int writerUpdateProtocolVersion,
                                int readerUpdateProtocolVersion)

Apply Update operation on the current value record.

Parameters:

currValue - value record that is currently stored on this Venice server. It is null when there is currently no value stored on this Venice server.

writeComputeBytes - serialized write-compute operation.

writerValueSchemaId - ID of the writer value schema.

readerValueSchemaId - ID of the reader value schema.

writerUpdateProtocolVersion - Update protocol version used to serialize Update payload bytes.

readerUpdateProtocolVersion - Update protocol version used to deserialize Update payload bytes.

Returns:

Bytes of partially updated original value.