org.apache.drill.exec.store.avro

Class AvroColumnConverterFactory

java.lang.Object

org.apache.drill.exec.record.ColumnConverterFactory

org.apache.drill.exec.store.avro.AvroColumnConverterFactory

public class AvroColumnConverterFactory
extends ColumnConverterFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroColumnConverterFactory.MapColumnConverter Converts and writes all map children using provided AvroColumnConverterFactory.MapColumnConverter.converters.

Constructor Summary

Constructors

Constructor and Description
AvroColumnConverterFactory(TupleMetadata providedSchema)

Method Summary

Modifier and Type	Method and Description
void	buildMapMembers(org.apache.avro.generic.GenericRecord genericRecord, TupleMetadata providedSchema, TupleWriter tupleWriter, List<ColumnConverter> converters)
ColumnConverter.ScalarColumnConverter	buildScalar(ColumnMetadata readerSchema, ValueWriter writer)
protected ColumnConverter	getMapConverter(TupleMetadata providedSchema, TupleMetadata readerSchema, TupleWriter tupleWriter) Based on provided schema, given converted Avro schema and current row writer generates list of column converters based on column type for AvroColumnConverterFactory.MapColumnConverter and returns it.
List<ColumnConverter>	initConverters(TupleMetadata providedSchema, TupleMetadata readerSchema, RowSetLoader rowWriter) Based on given converted Avro schema and current row writer generates list of column converters based on column type.

Methods inherited from class org.apache.drill.exec.record.ColumnConverterFactory

getConverter, getRootConverter

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroColumnConverterFactory

public AvroColumnConverterFactory(TupleMetadata providedSchema)

Method Detail

initConverters

public List<ColumnConverter> initConverters(TupleMetadata providedSchema,
                                            TupleMetadata readerSchema,
                                            RowSetLoader rowWriter)

Based on given converted Avro schema and current row writer generates list of column converters based on column type.

Parameters:

readerSchema - converted Avro schema

rowWriter - current row writer

Returns:

list of column converters

buildScalar

public ColumnConverter.ScalarColumnConverter buildScalar(ColumnMetadata readerSchema,
                                                         ValueWriter writer)

Overrides:

buildScalar in class ColumnConverterFactory

getMapConverter

protected ColumnConverter getMapConverter(TupleMetadata providedSchema,
                                          TupleMetadata readerSchema,
                                          TupleWriter tupleWriter)

Based on provided schema, given converted Avro schema and current row writer generates list of column converters based on column type for AvroColumnConverterFactory.MapColumnConverter and returns it.

Overrides:

getMapConverter in class ColumnConverterFactory

Parameters:

providedSchema - provided schema

readerSchema - converted Avro schema

tupleWriter - current row writer

Returns:

AvroColumnConverterFactory.MapColumnConverter with column converters

buildMapMembers

public void buildMapMembers(org.apache.avro.generic.GenericRecord genericRecord,
                            TupleMetadata providedSchema,
                            TupleWriter tupleWriter,
                            List<ColumnConverter> converters)