Package com.linkedin.davinci.schema.writecompute

Class WriteComputeHandlerV2

java.lang.Object

com.linkedin.venice.schema.writecompute.WriteComputeHandlerV1

com.linkedin.davinci.schema.writecompute.WriteComputeHandlerV2

All Implemented Interfaces:

WriteComputeHandler

public class WriteComputeHandlerV2
extends WriteComputeHandlerV1

Write compute V2 handles value records with replication metadata.

Method Summary

Modifier and Type	Method	Description
ValueAndRmd<org.apache.avro.generic.GenericRecord>	updateRecordWithRmd(org.apache.avro.Schema currValueSchema, ValueAndRmd<org.apache.avro.generic.GenericRecord> currRecordAndRmd, org.apache.avro.generic.GenericRecord writeComputeRecord, long updateOperationTimestamp, int coloID)	Handle partial update request on a value record that has associated replication metadata.

Methods inherited from class com.linkedin.venice.schema.writecompute.WriteComputeHandlerV1

updateValueRecord

Methods inherited from class java.lang.Object

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

Method Details

updateRecordWithRmd

public ValueAndRmd<org.apache.avro.generic.GenericRecord> updateRecordWithRmd(@Nonnull
 org.apache.avro.Schema currValueSchema,
 @Nonnull
 ValueAndRmd<org.apache.avro.generic.GenericRecord> currRecordAndRmd,
 @Nonnull
 org.apache.avro.generic.GenericRecord writeComputeRecord,
 long updateOperationTimestamp,
 int coloID)

Handle partial update request on a value record that has associated replication metadata.