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 and Description
AvroUtils()

Method Summary

Modifier and Type	Method and 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 Detail

AvroUtils

public AvroUtils()

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.