Package org.apache.drill.exec.store.kudu

Class KuduRecordWriter

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

org.apache.drill.exec.store.kudu.KuduRecordWriter

All Implemented Interfaces:

RecordWriter

Direct Known Subclasses:

KuduRecordWriterImpl

public abstract class KuduRecordWriter
extends AbstractRecordWriter
implements RecordWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	KuduRecordWriter.BigIntKuduConverter
class	KuduRecordWriter.BitKuduConverter
class	KuduRecordWriter.Decimal28DenseKuduConverter
class	KuduRecordWriter.Decimal38DenseKuduConverter
class	KuduRecordWriter.Float4KuduConverter
class	KuduRecordWriter.Float8KuduConverter
class	KuduRecordWriter.IntKuduConverter
class	KuduRecordWriter.NullableBigIntKuduConverter
class	KuduRecordWriter.NullableBitKuduConverter
class	KuduRecordWriter.NullableDecimal28DenseKuduConverter
class	KuduRecordWriter.NullableDecimal38DenseKuduConverter
class	KuduRecordWriter.NullableFloat4KuduConverter
class	KuduRecordWriter.NullableFloat8KuduConverter
class	KuduRecordWriter.NullableIntKuduConverter
class	KuduRecordWriter.NullableTimeStampKuduConverter
class	KuduRecordWriter.NullableUInt8KuduConverter
class	KuduRecordWriter.NullableVar16CharKuduConverter
class	KuduRecordWriter.NullableVarBinaryKuduConverter
class	KuduRecordWriter.NullableVarCharKuduConverter
class	KuduRecordWriter.NullableVarDecimalKuduConverter
class	KuduRecordWriter.TimeStampKuduConverter
class	KuduRecordWriter.UInt8KuduConverter
class	KuduRecordWriter.Var16CharKuduConverter
class	KuduRecordWriter.VarBinaryKuduConverter
class	KuduRecordWriter.VarCharKuduConverter
class	KuduRecordWriter.VarDecimalKuduConverter

Constructor Summary

Constructors

Constructor	Description
KuduRecordWriter()

Method Summary

Modifier and Type	Method	Description
EventBasedRecordWriter.FieldConverter	getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewBitConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewFloat4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewFloat8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableBitConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableFloat4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableTimeStampConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableUInt8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVar16CharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVarCharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewTimeStampConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewUInt8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVar16CharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
void	setUp(org.apache.kudu.client.PartialRow row)

Methods inherited from class org.apache.drill.exec.store.AbstractRecordWriter

checkForNewPartition, getNewDateConverter, getNewDecimal18Converter, getNewDecimal28SparseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewDictConverter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewMapConverter, getNewNullableDateConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTinyIntConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedDictConverter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedListConverter, getNewRepeatedMapConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewSmallIntConverter, getNewTimeConverter, getNewTinyIntConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUnionConverter, newPartition, postProcessing, setPartitionVector, supportsField

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.RecordWriter

abort, checkForNewPartition, cleanup, endRecord, getNewDateConverter, getNewDecimal18Converter, getNewDecimal28SparseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewDictConverter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewMapConverter, getNewNullableDateConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTinyIntConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedDictConverter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedListConverter, getNewRepeatedMapConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewSmallIntConverter, getNewTimeConverter, getNewTinyIntConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUnionConverter, init, postProcessing, startRecord, supportsField, updateSchema

Constructor Details

KuduRecordWriter

public KuduRecordWriter()

Method Details

setUp

public void setUp(org.apache.kudu.client.PartialRow row)

getNewNullableIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableIntConverter in interface RecordWriter

Overrides:

getNewNullableIntConverter in class AbstractRecordWriter

getNewIntConverter

public EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewIntConverter in interface RecordWriter

Overrides:

getNewIntConverter in class AbstractRecordWriter

getNewNullableFloat4Converter

public EventBasedRecordWriter.FieldConverter getNewNullableFloat4Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableFloat4Converter in interface RecordWriter

Overrides:

getNewNullableFloat4Converter in class AbstractRecordWriter

getNewFloat4Converter

public EventBasedRecordWriter.FieldConverter getNewFloat4Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewFloat4Converter in interface RecordWriter

Overrides:

getNewFloat4Converter in class AbstractRecordWriter

getNewNullableBigIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableBigIntConverter in interface RecordWriter

Overrides:

getNewNullableBigIntConverter in class AbstractRecordWriter

getNewBigIntConverter

public EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewBigIntConverter in interface RecordWriter

Overrides:

getNewBigIntConverter in class AbstractRecordWriter

getNewNullableUInt8Converter

public EventBasedRecordWriter.FieldConverter getNewNullableUInt8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableUInt8Converter in interface RecordWriter

Overrides:

getNewNullableUInt8Converter in class AbstractRecordWriter

getNewUInt8Converter

public EventBasedRecordWriter.FieldConverter getNewUInt8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewUInt8Converter in interface RecordWriter

Overrides:

getNewUInt8Converter in class AbstractRecordWriter

getNewNullableFloat8Converter

public EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableFloat8Converter in interface RecordWriter

Overrides:

getNewNullableFloat8Converter in class AbstractRecordWriter

getNewFloat8Converter

public EventBasedRecordWriter.FieldConverter getNewFloat8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewFloat8Converter in interface RecordWriter

Overrides:

getNewFloat8Converter in class AbstractRecordWriter

getNewNullableTimeStampConverter

public EventBasedRecordWriter.FieldConverter getNewNullableTimeStampConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableTimeStampConverter in interface RecordWriter

Overrides:

getNewNullableTimeStampConverter in class AbstractRecordWriter

getNewTimeStampConverter

public EventBasedRecordWriter.FieldConverter getNewTimeStampConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewTimeStampConverter in interface RecordWriter

Overrides:

getNewTimeStampConverter in class AbstractRecordWriter

getNewNullableDecimal28DenseConverter

public EventBasedRecordWriter.FieldConverter getNewNullableDecimal28DenseConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableDecimal28DenseConverter in interface RecordWriter

Overrides:

getNewNullableDecimal28DenseConverter in class AbstractRecordWriter

getNewDecimal28DenseConverter

public EventBasedRecordWriter.FieldConverter getNewDecimal28DenseConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewDecimal28DenseConverter in interface RecordWriter

Overrides:

getNewDecimal28DenseConverter in class AbstractRecordWriter

getNewNullableDecimal38DenseConverter

public EventBasedRecordWriter.FieldConverter getNewNullableDecimal38DenseConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableDecimal38DenseConverter in interface RecordWriter

Overrides:

getNewNullableDecimal38DenseConverter in class AbstractRecordWriter

getNewDecimal38DenseConverter

public EventBasedRecordWriter.FieldConverter getNewDecimal38DenseConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewDecimal38DenseConverter in interface RecordWriter

Overrides:

getNewDecimal38DenseConverter in class AbstractRecordWriter

getNewNullableVarBinaryConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVarBinaryConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVarBinaryConverter in interface RecordWriter

Overrides:

getNewNullableVarBinaryConverter in class AbstractRecordWriter

getNewVarBinaryConverter

public EventBasedRecordWriter.FieldConverter getNewVarBinaryConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVarBinaryConverter in interface RecordWriter

Overrides:

getNewVarBinaryConverter in class AbstractRecordWriter

getNewNullableVarCharConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVarCharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVarCharConverter in interface RecordWriter

Overrides:

getNewNullableVarCharConverter in class AbstractRecordWriter

getNewVarCharConverter

public EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVarCharConverter in interface RecordWriter

Overrides:

getNewVarCharConverter in class AbstractRecordWriter

getNewNullableVar16CharConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVar16CharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVar16CharConverter in interface RecordWriter

Overrides:

getNewNullableVar16CharConverter in class AbstractRecordWriter

getNewVar16CharConverter

public EventBasedRecordWriter.FieldConverter getNewVar16CharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVar16CharConverter in interface RecordWriter

Overrides:

getNewVar16CharConverter in class AbstractRecordWriter

getNewNullableVarDecimalConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVarDecimalConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVarDecimalConverter in interface RecordWriter

Overrides:

getNewNullableVarDecimalConverter in class AbstractRecordWriter

getNewVarDecimalConverter

public EventBasedRecordWriter.FieldConverter getNewVarDecimalConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVarDecimalConverter in interface RecordWriter

Overrides:

getNewVarDecimalConverter in class AbstractRecordWriter

getNewNullableBitConverter

public EventBasedRecordWriter.FieldConverter getNewNullableBitConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableBitConverter in interface RecordWriter

Overrides:

getNewNullableBitConverter in class AbstractRecordWriter

getNewBitConverter

public EventBasedRecordWriter.FieldConverter getNewBitConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewBitConverter in interface RecordWriter

Overrides:

getNewBitConverter in class AbstractRecordWriter