io.druid.data.input.avro

Class InlineSchemaAvroBytesDecoder

java.lang.Object

io.druid.data.input.avro.InlineSchemaAvroBytesDecoder

All Implemented Interfaces:

AvroBytesDecoder

public class InlineSchemaAvroBytesDecoder
extends Object
implements AvroBytesDecoder

Constructor Summary

Constructors

Constructor and Description
InlineSchemaAvroBytesDecoder(com.fasterxml.jackson.databind.ObjectMapper mapper, Map<String,Object> schema)

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getSchema()
org.apache.avro.generic.GenericRecord	parse(ByteBuffer bytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

InlineSchemaAvroBytesDecoder

public InlineSchemaAvroBytesDecoder(com.fasterxml.jackson.databind.ObjectMapper mapper,
                                    Map<String,Object> schema)
                             throws Exception

Throws:

Exception

Method Detail

getSchema

public Map<String,Object> getSchema()

parse

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

Specified by:

parse in interface AvroBytesDecoder