KuduRecordWriter (Drill : 1.20.3 API)

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 and 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 and Description

KuduRecordWriter()

Constructors
Constructor and Description
`KuduRecordWriter()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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 Detail
- KuduRecordWriter
```
public KuduRecordWriter()
```

Method Detail

setUp

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