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
All Methods Static Methods Concrete Methods 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.
-
-
-
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.
-
-