Package com.linkedin.venice.serialization.avro

Class VeniceSpecificDatumReader<T>

java.lang.Object
org.apache.avro.generic.GenericDatumReader<T>
org.apache.avro.specific.SpecificDatumReader<T>
com.linkedin.venice.serialization.avro.VeniceSpecificDatumReader<T>
All Implemented Interfaces:
org.apache.avro.io.DatumReader<T>
public class VeniceSpecificDatumReader<T> extends org.apache.avro.specific.SpecificDatumReader<T>

  • Constructor Summary

    Constructors
    Constructor
    Description
    VeniceSpecificDatumReader(org.apache.avro.Schema protocolSchema, org.apache.avro.Schema compiledProtocol)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected Object
    newMap(Object old, int size)
    Called to create new array instances.

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

    findStringClass, getSpecificData, readField, readRecord, setSchema

    Methods inherited from class org.apache.avro.generic.GenericDatumReader

    addToArray, addToMap, convert, createBytes, createEnum, createFixed, createFixed, createString, getData, getExpected, getResolver, getSchema, newArray, newInstanceFromString, newRecord, peekArray, read, read, readArray, readBytes, readBytes, readEnum, readFixed, readInt, readMap, readMapKey, readString, readString, readWithConversion, readWithoutConversion, setExpected, skip

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • VeniceSpecificDatumReader

      public VeniceSpecificDatumReader(org.apache.avro.Schema protocolSchema, org.apache.avro.Schema compiledProtocol)

  • Method Details

    • newMap

      protected Object newMap(Object old, int size)
      Called to create new array instances. To avoid concurrent modification error, returns VeniceConcurrentHashMap instead.
      Overrides:
      newMap in class org.apache.avro.generic.GenericDatumReader<T>