Class AvroUtils


  • public class AvroUtils
    extends Object
    • Constructor Detail

      • AvroUtils

        public AvroUtils()
    • Method Detail

      • addAvroKryoSerializations

        public static void addAvroKryoSerializations​(Config conf)
                                              throws ClassNotFoundException
        A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary. A default serializer will be provided if none is specified in the configuration. "avro.serializer" should specify the complete class name of the serializer, e.g. "org.apache.stgorm.hdfs.avro.GenericAvroSerializer"
        Parameters:
        conf - The topology configuration
        Throws:
        ClassNotFoundException - If the specified serializer cannot be located.