io.druid.data.input.avro

Class SchemaRegistryBasedAvroBytesDecoder

java.lang.Object

io.druid.data.input.avro.SchemaRegistryBasedAvroBytesDecoder

All Implemented Interfaces:

AvroBytesDecoder

public class SchemaRegistryBasedAvroBytesDecoder
extends Object
implements AvroBytesDecoder

Constructor Summary

Constructors

Constructor and Description
SchemaRegistryBasedAvroBytesDecoder(String url, Integer capacity)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
org.apache.avro.generic.GenericRecord	parse(ByteBuffer bytes)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SchemaRegistryBasedAvroBytesDecoder

public SchemaRegistryBasedAvroBytesDecoder(String url,
                                           Integer capacity)

Method Detail

parse

public org.apache.avro.generic.GenericRecord parse(ByteBuffer bytes)

Specified by:

parse in interface AvroBytesDecoder

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object