Class AvroUtils

java.lang.Object
org.apache.storm.hdfs.avro.AvroUtils

public class AvroUtils extends Object
  • Constructor Details

    • AvroUtils

      public AvroUtils()
  • Method Details

    • 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.