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.