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 voidaddAvroKryoSerializations(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.
-
-