Interface WriteComputeHandler

All Known Implementing Classes:
WriteComputeHandlerV1, WriteComputeHandlerV2

public interface WriteComputeHandler
This interface provides methods to execute write-compute operation a value
  • Method Summary

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

    • updateValueRecord

      org.apache.avro.generic.GenericRecord updateValueRecord(org.apache.avro.Schema valueSchema, org.apache.avro.generic.GenericRecord valueRecord, org.apache.avro.generic.GenericRecord writeComputeRecord)
      Execute write-compute operation on a value record.
      Parameters:
      valueSchema - Schema of the value record.
      valueRecord - 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.