Package org.apache.drill.exec.store.iceberg.read

Class IcebergColumnConverterFactory

java.lang.Object

org.apache.drill.exec.record.ColumnConverterFactory

org.apache.drill.exec.store.iceberg.read.IcebergColumnConverterFactory

public class IcebergColumnConverterFactory
extends ColumnConverterFactory

Constructor Summary

Constructors

Constructor	Description
IcebergColumnConverterFactory(TupleMetadata providedSchema)

Method Summary

Modifier and Type	Method	Description
ColumnConverter.ScalarColumnConverter	buildScalar(ColumnMetadata readerSchema, ValueWriter writer)
static TupleSchema	convertSchema(org.apache.iceberg.types.Types.StructType structType)
static ColumnMetadata	getColumnMetadata(org.apache.iceberg.types.Types.NestedField field)
protected ColumnConverter	getMapConverter(TupleMetadata providedSchema, TupleMetadata readerSchema, TupleWriter tupleWriter)

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 Details

IcebergColumnConverterFactory

public IcebergColumnConverterFactory(TupleMetadata providedSchema)

Method Details

getMapConverter

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

Overrides:

getMapConverter in class ColumnConverterFactory

buildScalar

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

Overrides:

buildScalar in class ColumnConverterFactory

getColumnMetadata

public static ColumnMetadata getColumnMetadata(org.apache.iceberg.types.Types.NestedField field)

convertSchema

public static TupleSchema convertSchema(org.apache.iceberg.types.Types.StructType structType)