Package com.linkedin.venice.compute.protocol.response

Class ComputeResponseRecordV1

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.compute.protocol.response.ComputeResponseRecordV1
All Implemented Interfaces:
Externalizable, Serializable, Comparable<org.apache.avro.specific.SpecificRecord>, org.apache.avro.generic.GenericContainer, org.apache.avro.generic.GenericRecord, org.apache.avro.generic.IndexedRecord, org.apache.avro.specific.SpecificRecord
public class ComputeResponseRecordV1 extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
This record used to store the response per key
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    int
    keyIndex
    This index will be used to retrieve the original key from the mapping maintained by Client/Router
    static final org.apache.avro.Schema
    SCHEMA$
     
    ByteBuffer
    value
    The serialized result can be de-serialized by the result schema passed in the compute request

  • Constructor Summary

    Constructors
    Constructor
    Description
    ComputeResponseRecordV1()
    Default constructor.
    ComputeResponseRecordV1(Integer keyIndex, ByteBuffer value)
    All-args constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    get(int field$)
     
    static org.apache.avro.Schema
    getClassSchema()
     
    int
    getKeyIndex()
    Gets the value of the 'keyIndex' field.
    org.apache.avro.Schema
    getSchema()
     
    org.apache.avro.specific.SpecificData
    getSpecificData()
     
    ByteBuffer
    getValue()
    Gets the value of the 'value' field.
    void
    put(int field$, Object value$)
     
    void
    readExternal(ObjectInput in)
     
    void
    setKeyIndex(int value)
    Sets the value of the 'keyIndex' field.
    void
    setValue(ByteBuffer value)
    Sets the value of the 'value' field.
    void
    writeExternal(ObjectOutput out)
     

    Methods inherited from class org.apache.avro.specific.SpecificRecordBase

    compareTo, customDecode, customEncode, equals, get, getConversion, getConversion, hasCustomCoders, hashCode, put, toString

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.apache.avro.generic.GenericRecord

    hasField

  • Field Details

    • SCHEMA$

      public static final org.apache.avro.Schema SCHEMA$

    • keyIndex

      public int keyIndex
      This index will be used to retrieve the original key from the mapping maintained by Client/Router

    • value

      public ByteBuffer value
      The serialized result can be de-serialized by the result schema passed in the compute request

  • Constructor Details

    • ComputeResponseRecordV1

      public ComputeResponseRecordV1()
      Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use newBuilder().

    • ComputeResponseRecordV1

      public ComputeResponseRecordV1(Integer keyIndex, ByteBuffer value)
      All-args constructor.
      Parameters:
      keyIndex - This index will be used to retrieve the original key from the mapping maintained by Client/Router
      value - The serialized result can be de-serialized by the result schema passed in the compute request

  • Method Details

    • getClassSchema

      public static org.apache.avro.Schema getClassSchema()

    • getSpecificData

      public org.apache.avro.specific.SpecificData getSpecificData()
      Overrides:
      getSpecificData in class org.apache.avro.specific.SpecificRecordBase

    • getSchema

      public org.apache.avro.Schema getSchema()
      Specified by:
      getSchema in interface org.apache.avro.generic.GenericContainer
      Specified by:
      getSchema in class org.apache.avro.specific.SpecificRecordBase

    • get

      public Object get(int field$)
      Specified by:
      get in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      get in class org.apache.avro.specific.SpecificRecordBase

    • put

      public void put(int field$, Object value$)
      Specified by:
      put in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      put in class org.apache.avro.specific.SpecificRecordBase

    • getKeyIndex

      public int getKeyIndex()
      Gets the value of the 'keyIndex' field.
      Returns:
      This index will be used to retrieve the original key from the mapping maintained by Client/Router

    • setKeyIndex

      public void setKeyIndex(int value)
      Sets the value of the 'keyIndex' field. This index will be used to retrieve the original key from the mapping maintained by Client/Router
      Parameters:
      value - the value to set.

    • getValue

      public ByteBuffer getValue()
      Gets the value of the 'value' field.
      Returns:
      The serialized result can be de-serialized by the result schema passed in the compute request

    • setValue

      public void setValue(ByteBuffer value)
      Sets the value of the 'value' field. The serialized result can be de-serialized by the result schema passed in the compute request
      Parameters:
      value - the value to set.

    • writeExternal

      public void writeExternal(ObjectOutput out) throws IOException
      Specified by:
      writeExternal in interface Externalizable
      Overrides:
      writeExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException

    • readExternal

      public void readExternal(ObjectInput in) throws IOException
      Specified by:
      readExternal in interface Externalizable
      Overrides:
      readExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException