Package com.linkedin.davinci.kafka.consumer

Class StoreWriteComputeProcessor

java.lang.Object

com.linkedin.davinci.kafka.consumer.StoreWriteComputeProcessor

public class StoreWriteComputeProcessor
extends Object

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
WriteComputeResult	applyWriteCompute(org.apache.avro.generic.GenericRecord currValue, int writerValueSchemaId, int readerValueSchemaId, 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 Details

StoreWriteComputeProcessor

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

Method Details

applyWriteCompute

public WriteComputeResult applyWriteCompute(org.apache.avro.generic.GenericRecord currValue,
 int writerValueSchemaId,
 int readerValueSchemaId,
 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:

WriteComputeResult of partially updated original value.