public class AvroUtils extends Object
Constructor and Description |
---|
AvroUtils() |
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.
|
public static void addAvroKryoSerializations(Config conf) throws ClassNotFoundException
conf
- The topology configurationClassNotFoundException
- If the specified serializer cannot be located.Copyright © 2016 The Apache Software Foundation. All Rights Reserved.