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

Class KuduRecordWriterImpl

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

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

org.apache.drill.exec.store.kudu.KuduRecordWriterImpl

All Implemented Interfaces:

RecordWriter

public class KuduRecordWriterImpl
extends KuduRecordWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.store.kudu.KuduRecordWriter

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

Constructor Summary

Constructors

Constructor	Description
KuduRecordWriterImpl(OperatorContext context, org.apache.kudu.client.KuduClient client, String name)

Method Summary

Modifier and Type	Method	Description
void	abort()
void	cleanup()
void	endRecord()	Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.
void	init(Map<String,String> writerOptions)	Initialize the writer.
void	startRecord()	Called before starting writing fields in a record.
void	updateSchema(VectorAccessible batch)	Update the schema in RecordWriter.

Methods inherited from class org.apache.drill.exec.store.kudu.KuduRecordWriter

getNewBigIntConverter, getNewBitConverter, getNewDecimal28DenseConverter, getNewDecimal38DenseConverter, getNewFloat4Converter, getNewFloat8Converter, getNewIntConverter, getNewNullableBigIntConverter, getNewNullableBitConverter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal38DenseConverter, getNewNullableFloat4Converter, getNewNullableFloat8Converter, getNewNullableIntConverter, getNewNullableTimeStampConverter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, getNewNullableVarBinaryConverter, getNewNullableVarCharConverter, getNewNullableVarDecimalConverter, getNewTimeStampConverter, getNewUInt8Converter, getNewVar16CharConverter, getNewVarBinaryConverter, getNewVarCharConverter, getNewVarDecimalConverter, setUp

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

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, postProcessing, supportsField

Constructor Details

KuduRecordWriterImpl

public KuduRecordWriterImpl(OperatorContext context,
 org.apache.kudu.client.KuduClient client,
 String name)

Method Details

init

public void init(Map<String,String> writerOptions)
          throws IOException

Description copied from interface: RecordWriter

Initialize the writer.

Parameters:

writerOptions - Contains key, value pair of settings.

Throws:

IOException

updateSchema

public void updateSchema(VectorAccessible batch)
                  throws IOException

Description copied from interface: RecordWriter

Update the schema in RecordWriter. Called at least once before starting writing the records.

Parameters:

batch -

Throws:

IOException

startRecord

public void startRecord()
                 throws IOException

Description copied from interface: RecordWriter

Called before starting writing fields in a record.

Throws:

IOException

endRecord

public void endRecord()
               throws IOException

Description copied from interface: RecordWriter

Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.

Throws:

IOException

abort

public void abort()
           throws IOException

Throws:

IOException

cleanup

public void cleanup()
             throws IOException

Throws:

IOException