org.apache.drill.exec.record

Class ColumnConverterFactory

java.lang.Object

org.apache.drill.exec.record.ColumnConverterFactory

Direct Known Subclasses:

AvroColumnConverterFactory, CassandraColumnConverterFactory, ElasticsearchColumnConverterFactory, IcebergColumnConverterFactory

public class ColumnConverterFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
ColumnConverterFactory(TupleMetadata providedSchema)

Method Summary

Modifier and Type	Method and Description
ColumnConverter.ScalarColumnConverter	buildScalar(ColumnMetadata readerSchema, ValueWriter writer)
ColumnConverter	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	getMapConverter(TupleMetadata providedSchema, TupleMetadata readerSchema, TupleWriter tupleWriter)
ColumnConverter	getRootConverter(TupleMetadata providedSchema, TupleMetadata readerSchema, TupleWriter tupleWriter)

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnConverterFactory

public ColumnConverterFactory(TupleMetadata providedSchema)

Method Detail

getRootConverter

public ColumnConverter getRootConverter(TupleMetadata providedSchema,
                                        TupleMetadata readerSchema,
                                        TupleWriter tupleWriter)

getConverter

public ColumnConverter 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. For columns which are not projected, ColumnConverter.DummyColumnConverter is used.

Parameters:

readerSchema - column metadata

writer - column writer

Returns:

column converter

getMapConverter

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

buildScalar

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