org.apache.drill.exec.store

Class EventBasedRecordWriter.FieldConverter

java.lang.Object

org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter

Direct Known Subclasses:

JdbcRecordWriter.BigIntJDBCConverter, JdbcRecordWriter.BitJDBCConverter, JdbcRecordWriter.DateJDBCConverter, JdbcRecordWriter.Float4JDBCConverter, JdbcRecordWriter.Float8JDBCConverter, JdbcRecordWriter.IntJDBCConverter, JdbcRecordWriter.NullableBigIntJDBCConverter, JdbcRecordWriter.NullableBitJDBCConverter, JdbcRecordWriter.NullableDateJDBCConverter, JdbcRecordWriter.NullableFloat4JDBCConverter, JdbcRecordWriter.NullableFloat8JDBCConverter, JdbcRecordWriter.NullableIntJDBCConverter, JdbcRecordWriter.NullableSmallIntJDBCConverter, JdbcRecordWriter.NullableTimeJDBCConverter, JdbcRecordWriter.NullableTimeStampJDBCConverter, JdbcRecordWriter.NullableTinyIntJDBCConverter, JdbcRecordWriter.NullableVarCharJDBCConverter, JdbcRecordWriter.NullableVardecimalJDBCConverter, JdbcRecordWriter.SmallIntJDBCConverter, JdbcRecordWriter.TimeJDBCConverter, JdbcRecordWriter.TimeStampJDBCConverter, JdbcRecordWriter.TinyIntJDBCConverter, JdbcRecordWriter.VarCharJDBCConverter, JdbcRecordWriter.VardecimalJDBCConverter, JSONBaseStatisticsRecordWriter.BigIntJsonConverter, JSONBaseStatisticsRecordWriter.BitJsonConverter, JSONBaseStatisticsRecordWriter.DateJsonConverter, JSONBaseStatisticsRecordWriter.Decimal18JsonConverter, JSONBaseStatisticsRecordWriter.Decimal28DenseJsonConverter, JSONBaseStatisticsRecordWriter.Decimal28SparseJsonConverter, JSONBaseStatisticsRecordWriter.Decimal38DenseJsonConverter, JSONBaseStatisticsRecordWriter.Decimal38SparseJsonConverter, JSONBaseStatisticsRecordWriter.Decimal9JsonConverter, JSONBaseStatisticsRecordWriter.Float4JsonConverter, JSONBaseStatisticsRecordWriter.Float8JsonConverter, JSONBaseStatisticsRecordWriter.IntervalDayJsonConverter, JSONBaseStatisticsRecordWriter.IntervalJsonConverter, JSONBaseStatisticsRecordWriter.IntervalYearJsonConverter, JSONBaseStatisticsRecordWriter.IntJsonConverter, JSONBaseStatisticsRecordWriter.NullableBigIntJsonConverter, JSONBaseStatisticsRecordWriter.NullableBitJsonConverter, JSONBaseStatisticsRecordWriter.NullableDateJsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal18JsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal28DenseJsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal28SparseJsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal38DenseJsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal38SparseJsonConverter, JSONBaseStatisticsRecordWriter.NullableDecimal9JsonConverter, JSONBaseStatisticsRecordWriter.NullableFloat4JsonConverter, JSONBaseStatisticsRecordWriter.NullableFloat8JsonConverter, JSONBaseStatisticsRecordWriter.NullableIntervalDayJsonConverter, JSONBaseStatisticsRecordWriter.NullableIntervalJsonConverter, JSONBaseStatisticsRecordWriter.NullableIntervalYearJsonConverter, JSONBaseStatisticsRecordWriter.NullableIntJsonConverter, JSONBaseStatisticsRecordWriter.NullableSmallIntJsonConverter, JSONBaseStatisticsRecordWriter.NullableTimeJsonConverter, JSONBaseStatisticsRecordWriter.NullableTimeStampJsonConverter, JSONBaseStatisticsRecordWriter.NullableTinyIntJsonConverter, JSONBaseStatisticsRecordWriter.NullableUInt1JsonConverter, JSONBaseStatisticsRecordWriter.NullableUInt2JsonConverter, JSONBaseStatisticsRecordWriter.NullableUInt4JsonConverter, JSONBaseStatisticsRecordWriter.NullableUInt8JsonConverter, JSONBaseStatisticsRecordWriter.NullableVar16CharJsonConverter, JSONBaseStatisticsRecordWriter.NullableVarBinaryJsonConverter, JSONBaseStatisticsRecordWriter.NullableVarCharJsonConverter, JSONBaseStatisticsRecordWriter.NullableVarDecimalJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedBigIntJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedBitJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDateJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal18JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal28DenseJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal28SparseJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal38DenseJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal38SparseJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedDecimal9JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedFloat4JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedFloat8JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedIntervalDayJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedIntervalJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedIntervalYearJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedIntJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedSmallIntJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedTimeJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedTimeStampJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedTinyIntJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedUInt1JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedUInt2JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedUInt4JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedUInt8JsonConverter, JSONBaseStatisticsRecordWriter.RepeatedVar16CharJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedVarBinaryJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedVarCharJsonConverter, JSONBaseStatisticsRecordWriter.RepeatedVarDecimalJsonConverter, JSONBaseStatisticsRecordWriter.SmallIntJsonConverter, JSONBaseStatisticsRecordWriter.TimeJsonConverter, JSONBaseStatisticsRecordWriter.TimeStampJsonConverter, JSONBaseStatisticsRecordWriter.TinyIntJsonConverter, JSONBaseStatisticsRecordWriter.UInt1JsonConverter, JSONBaseStatisticsRecordWriter.UInt2JsonConverter, JSONBaseStatisticsRecordWriter.UInt4JsonConverter, JSONBaseStatisticsRecordWriter.UInt8JsonConverter, JSONBaseStatisticsRecordWriter.Var16CharJsonConverter, JSONBaseStatisticsRecordWriter.VarBinaryJsonConverter, JSONBaseStatisticsRecordWriter.VarCharJsonConverter, JSONBaseStatisticsRecordWriter.VarDecimalJsonConverter, JSONOutputRecordWriter.BigIntJsonConverter, JSONOutputRecordWriter.BitJsonConverter, JSONOutputRecordWriter.DateJsonConverter, JSONOutputRecordWriter.Decimal18JsonConverter, JSONOutputRecordWriter.Decimal28DenseJsonConverter, JSONOutputRecordWriter.Decimal28SparseJsonConverter, JSONOutputRecordWriter.Decimal38DenseJsonConverter, JSONOutputRecordWriter.Decimal38SparseJsonConverter, JSONOutputRecordWriter.Decimal9JsonConverter, JSONOutputRecordWriter.Float4JsonConverter, JSONOutputRecordWriter.Float8JsonConverter, JSONOutputRecordWriter.IntervalDayJsonConverter, JSONOutputRecordWriter.IntervalJsonConverter, JSONOutputRecordWriter.IntervalYearJsonConverter, JSONOutputRecordWriter.IntJsonConverter, JSONOutputRecordWriter.NullableBigIntJsonConverter, JSONOutputRecordWriter.NullableBitJsonConverter, JSONOutputRecordWriter.NullableDateJsonConverter, JSONOutputRecordWriter.NullableDecimal18JsonConverter, JSONOutputRecordWriter.NullableDecimal28DenseJsonConverter, JSONOutputRecordWriter.NullableDecimal28SparseJsonConverter, JSONOutputRecordWriter.NullableDecimal38DenseJsonConverter, JSONOutputRecordWriter.NullableDecimal38SparseJsonConverter, JSONOutputRecordWriter.NullableDecimal9JsonConverter, JSONOutputRecordWriter.NullableFloat4JsonConverter, JSONOutputRecordWriter.NullableFloat8JsonConverter, JSONOutputRecordWriter.NullableIntervalDayJsonConverter, JSONOutputRecordWriter.NullableIntervalJsonConverter, JSONOutputRecordWriter.NullableIntervalYearJsonConverter, JSONOutputRecordWriter.NullableIntJsonConverter, JSONOutputRecordWriter.NullableSmallIntJsonConverter, JSONOutputRecordWriter.NullableTimeJsonConverter, JSONOutputRecordWriter.NullableTimeStampJsonConverter, JSONOutputRecordWriter.NullableTinyIntJsonConverter, JSONOutputRecordWriter.NullableUInt1JsonConverter, JSONOutputRecordWriter.NullableUInt2JsonConverter, JSONOutputRecordWriter.NullableUInt4JsonConverter, JSONOutputRecordWriter.NullableUInt8JsonConverter, JSONOutputRecordWriter.NullableVar16CharJsonConverter, JSONOutputRecordWriter.NullableVarBinaryJsonConverter, JSONOutputRecordWriter.NullableVarCharJsonConverter, JSONOutputRecordWriter.NullableVarDecimalJsonConverter, JSONOutputRecordWriter.RepeatedBigIntJsonConverter, JSONOutputRecordWriter.RepeatedBitJsonConverter, JSONOutputRecordWriter.RepeatedDateJsonConverter, JSONOutputRecordWriter.RepeatedDecimal18JsonConverter, JSONOutputRecordWriter.RepeatedDecimal28DenseJsonConverter, JSONOutputRecordWriter.RepeatedDecimal28SparseJsonConverter, JSONOutputRecordWriter.RepeatedDecimal38DenseJsonConverter, JSONOutputRecordWriter.RepeatedDecimal38SparseJsonConverter, JSONOutputRecordWriter.RepeatedDecimal9JsonConverter, JSONOutputRecordWriter.RepeatedFloat4JsonConverter, JSONOutputRecordWriter.RepeatedFloat8JsonConverter, JSONOutputRecordWriter.RepeatedIntervalDayJsonConverter, JSONOutputRecordWriter.RepeatedIntervalJsonConverter, JSONOutputRecordWriter.RepeatedIntervalYearJsonConverter, JSONOutputRecordWriter.RepeatedIntJsonConverter, JSONOutputRecordWriter.RepeatedSmallIntJsonConverter, JSONOutputRecordWriter.RepeatedTimeJsonConverter, JSONOutputRecordWriter.RepeatedTimeStampJsonConverter, JSONOutputRecordWriter.RepeatedTinyIntJsonConverter, JSONOutputRecordWriter.RepeatedUInt1JsonConverter, JSONOutputRecordWriter.RepeatedUInt2JsonConverter, JSONOutputRecordWriter.RepeatedUInt4JsonConverter, JSONOutputRecordWriter.RepeatedUInt8JsonConverter, JSONOutputRecordWriter.RepeatedVar16CharJsonConverter, JSONOutputRecordWriter.RepeatedVarBinaryJsonConverter, JSONOutputRecordWriter.RepeatedVarCharJsonConverter, JSONOutputRecordWriter.RepeatedVarDecimalJsonConverter, JSONOutputRecordWriter.SmallIntJsonConverter, JSONOutputRecordWriter.TimeJsonConverter, JSONOutputRecordWriter.TimeStampJsonConverter, JSONOutputRecordWriter.TinyIntJsonConverter, JSONOutputRecordWriter.UInt1JsonConverter, JSONOutputRecordWriter.UInt2JsonConverter, JSONOutputRecordWriter.UInt4JsonConverter, JSONOutputRecordWriter.UInt8JsonConverter, JSONOutputRecordWriter.Var16CharJsonConverter, JSONOutputRecordWriter.VarBinaryJsonConverter, JSONOutputRecordWriter.VarCharJsonConverter, JSONOutputRecordWriter.VarDecimalJsonConverter, JsonRecordWriter.MapJsonConverter, JsonRecordWriter.RepeatedListJsonConverter, JsonRecordWriter.RepeatedMapJsonConverter, JsonRecordWriter.UnionJsonConverter, KuduRecordWriter.BigIntKuduConverter, KuduRecordWriter.BitKuduConverter, KuduRecordWriter.Decimal28DenseKuduConverter, KuduRecordWriter.Decimal38DenseKuduConverter, KuduRecordWriter.Float4KuduConverter, KuduRecordWriter.Float8KuduConverter, KuduRecordWriter.IntKuduConverter, KuduRecordWriter.NullableBigIntKuduConverter, KuduRecordWriter.NullableBitKuduConverter, KuduRecordWriter.NullableDecimal28DenseKuduConverter, KuduRecordWriter.NullableDecimal38DenseKuduConverter, KuduRecordWriter.NullableFloat4KuduConverter, KuduRecordWriter.NullableFloat8KuduConverter, KuduRecordWriter.NullableIntKuduConverter, KuduRecordWriter.NullableTimeStampKuduConverter, KuduRecordWriter.NullableUInt8KuduConverter, KuduRecordWriter.NullableVar16CharKuduConverter, KuduRecordWriter.NullableVarBinaryKuduConverter, KuduRecordWriter.NullableVarCharKuduConverter, KuduRecordWriter.NullableVarDecimalKuduConverter, KuduRecordWriter.TimeStampKuduConverter, KuduRecordWriter.UInt8KuduConverter, KuduRecordWriter.Var16CharKuduConverter, KuduRecordWriter.VarBinaryKuduConverter, KuduRecordWriter.VarCharKuduConverter, KuduRecordWriter.VarDecimalKuduConverter, ParquetOutputRecordWriter.BaseFieldConverter, ParquetOutputRecordWriter.NullableFieldConverter, ParquetOutputRecordWriter.RepeatedFieldConverter, ParquetOutputRecordWriter.RequiredFieldConverter, ParquetRecordWriter.DictParquetConverter, ParquetRecordWriter.MapParquetConverter, ParquetRecordWriter.RepeatedDictParquetConverter, ParquetRecordWriter.RepeatedListParquetConverter, ParquetRecordWriter.RepeatedMapParquetConverter, StatisticsCollectorImpl.BigIntJsonConverter, StatisticsCollectorImpl.DateJsonConverter, StatisticsCollectorImpl.IntJsonConverter, StatisticsCollectorImpl.NullableBigIntJsonConverter, StatisticsCollectorImpl.NullableFloat8JsonConverter, StatisticsCollectorImpl.NullableVarBinaryJsonConverter, StatisticsCollectorImpl.VarCharJsonConverter, StringOutputRecordWriter.BigIntStringFieldConverter, StringOutputRecordWriter.BitStringFieldConverter, StringOutputRecordWriter.DateStringFieldConverter, StringOutputRecordWriter.Decimal18StringFieldConverter, StringOutputRecordWriter.Decimal28DenseStringFieldConverter, StringOutputRecordWriter.Decimal28SparseStringFieldConverter, StringOutputRecordWriter.Decimal38DenseStringFieldConverter, StringOutputRecordWriter.Decimal38SparseStringFieldConverter, StringOutputRecordWriter.Decimal9StringFieldConverter, StringOutputRecordWriter.Float4StringFieldConverter, StringOutputRecordWriter.Float8StringFieldConverter, StringOutputRecordWriter.IntervalDayStringFieldConverter, StringOutputRecordWriter.IntervalStringFieldConverter, StringOutputRecordWriter.IntervalYearStringFieldConverter, StringOutputRecordWriter.IntStringFieldConverter, StringOutputRecordWriter.NullableBigIntStringFieldConverter, StringOutputRecordWriter.NullableBitStringFieldConverter, StringOutputRecordWriter.NullableDateStringFieldConverter, StringOutputRecordWriter.NullableDecimal18StringFieldConverter, StringOutputRecordWriter.NullableDecimal28DenseStringFieldConverter, StringOutputRecordWriter.NullableDecimal28SparseStringFieldConverter, StringOutputRecordWriter.NullableDecimal38DenseStringFieldConverter, StringOutputRecordWriter.NullableDecimal38SparseStringFieldConverter, StringOutputRecordWriter.NullableDecimal9StringFieldConverter, StringOutputRecordWriter.NullableFloat4StringFieldConverter, StringOutputRecordWriter.NullableFloat8StringFieldConverter, StringOutputRecordWriter.NullableIntervalDayStringFieldConverter, StringOutputRecordWriter.NullableIntervalStringFieldConverter, StringOutputRecordWriter.NullableIntervalYearStringFieldConverter, StringOutputRecordWriter.NullableIntStringFieldConverter, StringOutputRecordWriter.NullableSmallIntStringFieldConverter, StringOutputRecordWriter.NullableTimeStampStringFieldConverter, StringOutputRecordWriter.NullableTimeStringFieldConverter, StringOutputRecordWriter.NullableTinyIntStringFieldConverter, StringOutputRecordWriter.NullableUInt1StringFieldConverter, StringOutputRecordWriter.NullableUInt2StringFieldConverter, StringOutputRecordWriter.NullableUInt4StringFieldConverter, StringOutputRecordWriter.NullableUInt8StringFieldConverter, StringOutputRecordWriter.NullableVar16CharStringFieldConverter, StringOutputRecordWriter.NullableVarBinaryStringFieldConverter, StringOutputRecordWriter.NullableVarCharStringFieldConverter, StringOutputRecordWriter.NullableVarDecimalStringFieldConverter, StringOutputRecordWriter.RepeatedBigIntStringFieldConverter, StringOutputRecordWriter.RepeatedBitStringFieldConverter, StringOutputRecordWriter.RepeatedDateStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal18StringFieldConverter, StringOutputRecordWriter.RepeatedDecimal28DenseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal28SparseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal38DenseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal38SparseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal9StringFieldConverter, StringOutputRecordWriter.RepeatedFloat4StringFieldConverter, StringOutputRecordWriter.RepeatedFloat8StringFieldConverter, StringOutputRecordWriter.RepeatedIntervalDayStringFieldConverter, StringOutputRecordWriter.RepeatedIntervalStringFieldConverter, StringOutputRecordWriter.RepeatedIntervalYearStringFieldConverter, StringOutputRecordWriter.RepeatedIntStringFieldConverter, StringOutputRecordWriter.RepeatedSmallIntStringFieldConverter, StringOutputRecordWriter.RepeatedTimeStampStringFieldConverter, StringOutputRecordWriter.RepeatedTimeStringFieldConverter, StringOutputRecordWriter.RepeatedTinyIntStringFieldConverter, StringOutputRecordWriter.RepeatedUInt1StringFieldConverter, StringOutputRecordWriter.RepeatedUInt2StringFieldConverter, StringOutputRecordWriter.RepeatedUInt4StringFieldConverter, StringOutputRecordWriter.RepeatedUInt8StringFieldConverter, StringOutputRecordWriter.RepeatedVar16CharStringFieldConverter, StringOutputRecordWriter.RepeatedVarBinaryStringFieldConverter, StringOutputRecordWriter.RepeatedVarCharStringFieldConverter, StringOutputRecordWriter.RepeatedVarDecimalStringFieldConverter, StringOutputRecordWriter.SmallIntStringFieldConverter, StringOutputRecordWriter.TimeStampStringFieldConverter, StringOutputRecordWriter.TimeStringFieldConverter, StringOutputRecordWriter.TinyIntStringFieldConverter, StringOutputRecordWriter.UInt1StringFieldConverter, StringOutputRecordWriter.UInt2StringFieldConverter, StringOutputRecordWriter.UInt4StringFieldConverter, StringOutputRecordWriter.UInt8StringFieldConverter, StringOutputRecordWriter.Var16CharStringFieldConverter, StringOutputRecordWriter.VarBinaryStringFieldConverter, StringOutputRecordWriter.VarCharStringFieldConverter, StringOutputRecordWriter.VarDecimalStringFieldConverter, TextRecordWriter.ComplexStringFieldConverter

Enclosing class:

EventBasedRecordWriter

public abstract static class EventBasedRecordWriter.FieldConverter
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	fieldId
protected String	fieldName
protected FieldReader	reader

Constructor Summary

Constructors

Constructor and Description
FieldConverter(int fieldId, String fieldName, FieldReader reader)

Method Summary

Modifier and Type	Method and Description
void	endField()
void	setPosition(int index)
void	startField()
abstract void	writeField()
void	writeListField() Used by repeated converters for writing Parquet logical lists.

Methods inherited from class java.lang.Object

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

Field Detail

fieldId

protected int fieldId

fieldName

protected String fieldName

reader

protected FieldReader reader

Constructor Detail

FieldConverter

public FieldConverter(int fieldId,
                      String fieldName,
                      FieldReader reader)

Method Detail

setPosition

public void setPosition(int index)

startField

public void startField()
                throws IOException

Throws:

IOException

endField

public void endField()
              throws IOException

Throws:

IOException

writeField

public abstract void writeField()
                         throws IOException

Throws:

IOException

writeListField

public void writeListField()
                    throws IOException

Used by repeated converters for writing Parquet logical lists.

Throws:

IOException - may be thrown by subsequent invocation of {writeField()} in overriden methods

See Also:

Lists