io.druid.data.input.avro

Class AvroFlattenerMaker

java.lang.Object

io.druid.data.input.avro.AvroFlattenerMaker

All Implemented Interfaces:

ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>

public class AvroFlattenerMaker
extends Object
implements ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>

Constructor Summary

Constructors

Constructor and Description
AvroFlattenerMaker(boolean fromPigAvroStorage, boolean binaryAsString)

Method Summary

Modifier and Type	Method and Description
Set<String>	discoverRootFields(org.apache.avro.generic.GenericRecord obj)
Object	getRootField(org.apache.avro.generic.GenericRecord record, String key)
Function<org.apache.avro.generic.GenericRecord,Object>	makeJsonPathExtractor(String expr)
Function<org.apache.avro.generic.GenericRecord,Object>	makeJsonQueryExtractor(String expr)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroFlattenerMaker

public AvroFlattenerMaker(boolean fromPigAvroStorage,
                          boolean binaryAsString)

Method Detail

discoverRootFields

public Set<String> discoverRootFields(org.apache.avro.generic.GenericRecord obj)

Specified by:

discoverRootFields in interface ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>

getRootField

public Object getRootField(org.apache.avro.generic.GenericRecord record,
                           String key)

Specified by:

getRootField in interface ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>

makeJsonPathExtractor

public Function<org.apache.avro.generic.GenericRecord,Object> makeJsonPathExtractor(String expr)

Specified by:

makeJsonPathExtractor in interface ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>

makeJsonQueryExtractor

public Function<org.apache.avro.generic.GenericRecord,Object> makeJsonQueryExtractor(String expr)

Specified by:

makeJsonQueryExtractor in interface ObjectFlatteners.FlattenerMaker<org.apache.avro.generic.GenericRecord>