Package org.apache.drill.exec.physical.impl.scan.convert

Class ColumnConverter

java.lang.Object

org.apache.drill.exec.physical.impl.scan.convert.ColumnConverter

Direct Known Subclasses:

DirectConverter

public class ColumnConverter
extends Object

Base class for any kind of column converter. Extend this class if your columns work with reader-specific types, such as having to call a type-specific method on some row object. In this case, all your subclasses would implement the same method, say void convertValue(MyRow row). Subclases might know their column indexes within the row object, extract the value using type-specific methods, then pass the value onto the scalar writer.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ScalarWriter	baseWriter

Constructor Summary

Constructors

Constructor	Description
ColumnConverter(ScalarWriter colWriter)

Method Summary

Modifier and Type	Method	Description
protected UnsupportedConversionError	conversionError(String javaType)
ColumnMetadata	schema()
ScalarWriter	writer()

Methods inherited from class java.lang.Object

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

Field Details

baseWriter

protected final ScalarWriter baseWriter

Constructor Details

ColumnConverter

public ColumnConverter(ScalarWriter colWriter)

Method Details

writer

public ScalarWriter writer()

schema

public ColumnMetadata schema()

conversionError

protected UnsupportedConversionError conversionError(String javaType)