Package org.apache.storm.hdfs.avro

# Class AvroUtils

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

public class AvroUtils extends Object

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `AvroUtils()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `static void`
  `addAvroKryoSerializations(Config conf)`
  A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary.

  ### Methods inherited from class java.lang.Object

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

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