Package com.linkedin.venice.serialization.avro

Class 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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected java.lang.Object newMap​(java.lang.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 Detail

      • VeniceSpecificDatumReader

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

    • Method Detail

      • newMap

        protected java.lang.Object newMap​(java.lang.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>