Package org.apache.storm.hdfs.avro
Class AvroUtils
java.lang.Object
org.apache.storm.hdfs.avro.AvroUtils
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidA helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary.
- 
Constructor Details- 
AvroUtilspublic AvroUtils()
 
- 
- 
Method Details- 
addAvroKryoSerializationsA 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.
 
 
-