Package com.linkedin.venice.schema.writecompute

Class WriteComputeHandlerV1

java.lang.Object

com.linkedin.venice.schema.writecompute.WriteComputeHandlerV1

All Implemented Interfaces:

WriteComputeHandler

Direct Known Subclasses:

WriteComputeHandlerV2

public class WriteComputeHandlerV1
extends java.lang.Object
implements WriteComputeHandler

Write compute V1 handles value records that do not have replication metadata.

Constructor Summary

Constructors

Constructor	Description
WriteComputeHandlerV1()

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	updateValueRecord(org.apache.avro.Schema valueSchema, org.apache.avro.generic.GenericRecord currValue, org.apache.avro.generic.GenericRecord writeComputeRecord)	Execute write-compute operation on a value record.

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteComputeHandlerV1

public WriteComputeHandlerV1()

Method Detail

updateValueRecord

public org.apache.avro.generic.GenericRecord updateValueRecord(org.apache.avro.Schema valueSchema,
                                                               org.apache.avro.generic.GenericRecord currValue,
                                                               org.apache.avro.generic.GenericRecord writeComputeRecord)

Description copied from interface: WriteComputeHandler

Execute write-compute operation on a value record.

Specified by:

updateValueRecord in interface WriteComputeHandler

Parameters:

valueSchema - Schema of the value record.

currValue - Value record. Note that the this object may be mutated in the implementation of this method and the returned object may be reference equal to this input object. When it is Optional.empty(), it means that there is currently no value.

writeComputeRecord - Write compute schema

Returns:

updated value record.