| Package | Description |
|---|---|
| org.apache.drill.exec.record | |
| org.apache.drill.exec.store.avro |
| Modifier and Type | Class and Description |
|---|---|
static class |
ColumnConverter.ArrayColumnConverter
Converts and writes array values using
ColumnConverter.ArrayColumnConverter.valueConverter
into ColumnConverter.ArrayColumnConverter.arrayWriter. |
static class |
ColumnConverter.DictColumnConverter
Converts and writes dict values using provided key / value converters.
|
static class |
ColumnConverter.DummyColumnConverter
Does nothing, is used when column is not projected to avoid unnecessary
column values conversions and writes.
|
static class |
ColumnConverter.MapColumnConverter
Converts and writes all map children using provided
ColumnConverter.MapColumnConverter.converters. |
static class |
ColumnConverter.ScalarColumnConverter
Converts and writes scalar values using provided
ColumnConverter.ScalarColumnConverter.valueConverter. |
| Modifier and Type | Method and Description |
|---|---|
ColumnConverter |
ColumnConverterFactory.getConverter(TupleMetadata providedSchema,
ColumnMetadata readerSchema,
ObjectWriter writer)
Based on column type, creates corresponding column converter
which holds conversion logic and appropriate writer to set converted data into.
|
protected ColumnConverter |
ColumnConverterFactory.getMapConverter(TupleMetadata providedSchema,
TupleMetadata readerSchema,
TupleWriter tupleWriter) |
ColumnConverter |
ColumnConverterFactory.getRootConverter(TupleMetadata providedSchema,
TupleMetadata readerSchema,
TupleWriter tupleWriter) |
| Constructor and Description |
|---|
ArrayColumnConverter(ArrayWriter arrayWriter,
ColumnConverter valueConverter) |
DictColumnConverter(DictWriter dictWriter,
ColumnConverter keyConverter,
ColumnConverter valueConverter) |
| Constructor and Description |
|---|
MapColumnConverter(ColumnConverterFactory factory,
TupleMetadata providedSchema,
TupleWriter tupleWriter,
Map<String,ColumnConverter> converters) |
| Modifier and Type | Class and Description |
|---|---|
static class |
AvroColumnConverterFactory.MapColumnConverter
Converts and writes all map children using provided
AvroColumnConverterFactory.MapColumnConverter.converters. |
| Modifier and Type | Method and Description |
|---|---|
protected ColumnConverter |
AvroColumnConverterFactory.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. |
| Modifier and Type | Method and Description |
|---|---|
List<ColumnConverter> |
AvroColumnConverterFactory.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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AvroColumnConverterFactory.buildMapMembers(org.apache.avro.generic.GenericRecord genericRecord,
TupleMetadata providedSchema,
TupleWriter tupleWriter,
List<ColumnConverter> converters) |
| Constructor and Description |
|---|
MapColumnConverter(AvroColumnConverterFactory factory,
TupleMetadata providedSchema,
TupleWriter tupleWriter,
List<ColumnConverter> converters) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.