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

Class DirectConverter

java.lang.Object

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

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

All Implemented Interfaces:

ValueWriter

Direct Known Subclasses:

AbstractConvertFromString, ConvertBooleanToString, ConvertDateToString, ConvertDecimalToString, ConvertDoubleToDecimal, ConvertDoubleToString, ConvertFloatToDecimal, ConvertIntervalToString, ConvertIntToDecimal, ConvertIntToString, ConvertLongToDecimal, ConvertLongToString, ConvertTimeStampToString, ConvertTimeToString

public class DirectConverter
extends ColumnConverter
implements ValueWriter

Base class for Java type-based conversion. Use this base class if your reader works with Java types, but you need to convert from one Java type to another (such as decoding a byte array, converting a string to a number, etc.)

Instances of this class can be freely mixed with "plain" ScalarWriter instances to avoid unnecessary calls when there is a direct mapping from reader Java type to Drill type. You only need insert converters for those columns where some conversion step is needed.

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.scan.convert.ColumnConverter

baseWriter

Constructor Summary

Constructors

Constructor and Description
DirectConverter(ScalarWriter colWriter)

Method Summary

Modifier and Type	Method and Description
void	appendBytes(byte[] value, int len)
void	setBoolean(boolean value)
void	setBytes(byte[] value, int len)
void	setDate(LocalDate value)
void	setDecimal(BigDecimal value)
void	setDouble(double value)
void	setFloat(float value)
void	setInt(int value)
void	setLong(long value)
void	setNull() Set the current value to null.
void	setPeriod(org.joda.time.Period value)
void	setString(String value)
void	setTime(LocalTime value)
void	setTimestamp(Instant value)
void	setValue(Object value) Write value to a vector as a Java object of the "native" type for the column.

Methods inherited from class org.apache.drill.exec.physical.impl.scan.convert.ColumnConverter

conversionError, schema, writer

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectConverter

public DirectConverter(ScalarWriter colWriter)

Method Detail

setNull

public void setNull()

Description copied from interface: ValueWriter

Set the current value to null. throws IllegalStateException if called on a non-nullable value.

Specified by:

setNull in interface ValueWriter

setBoolean

public void setBoolean(boolean value)

Specified by:

setBoolean in interface ValueWriter

setInt

public void setInt(int value)

Specified by:

setInt in interface ValueWriter

setLong

public void setLong(long value)

Specified by:

setLong in interface ValueWriter

setFloat

public void setFloat(float value)

Specified by:

setFloat in interface ValueWriter

setDouble

public void setDouble(double value)

Specified by:

setDouble in interface ValueWriter

setString

public void setString(String value)

Specified by:

setString in interface ValueWriter

setBytes

public void setBytes(byte[] value,
                     int len)

Specified by:

setBytes in interface ValueWriter

appendBytes

public void appendBytes(byte[] value,
                        int len)

Specified by:

appendBytes in interface ValueWriter

setDecimal

public void setDecimal(BigDecimal value)

Specified by:

setDecimal in interface ValueWriter

setPeriod

public void setPeriod(org.joda.time.Period value)

Specified by:

setPeriod in interface ValueWriter

setDate

public void setDate(LocalDate value)

Specified by:

setDate in interface ValueWriter

setTime

public void setTime(LocalTime value)

Specified by:

setTime in interface ValueWriter

setTimestamp

public void setTimestamp(Instant value)

Specified by:

setTimestamp in interface ValueWriter

setValue

public void setValue(Object value)

Description copied from interface: ValueWriter

Write value to a vector as a Java object of the "native" type for the column. This form is available only on scalar writers. The object must be of the form for the primary write method above.

Primarily to be used when the code already knows the object type.

Specified by:

setValue in interface ValueWriter

Parameters:

value - a value that matches the primary setter above, or null to set the column to null

See Also:

for the generic case