io.druid.data.input.avro

Class InlineSchemasAvroBytesDecoder

java.lang.Object

io.druid.data.input.avro.InlineSchemasAvroBytesDecoder

All Implemented Interfaces:

AvroBytesDecoder

public class InlineSchemasAvroBytesDecoder
extends Object
implements AvroBytesDecoder

Constructor Summary

Constructors

Constructor and Description
InlineSchemasAvroBytesDecoder(Map<Integer,org.apache.avro.Schema> schemaObjs)
InlineSchemasAvroBytesDecoder(com.fasterxml.jackson.databind.ObjectMapper mapper, Map<String,Map<String,Object>> schemas)

Method Summary

Modifier and Type	Method and Description
Map<String,Map<String,Object>>	getSchemas()
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

InlineSchemasAvroBytesDecoder

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

Throws:

Exception

InlineSchemasAvroBytesDecoder

public InlineSchemasAvroBytesDecoder(Map<Integer,org.apache.avro.Schema> schemaObjs)

Method Detail

getSchemas

public Map<String,Map<String,Object>> getSchemas()

parse

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

Specified by:

parse in interface AvroBytesDecoder