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:

org.apache.drill.exec.store.RecordWriter

public class KuduRecordWriterImpl
extends org.apache.drill.exec.store.kudu.KuduRecordWriter

Nested Class Summary

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

org.apache.drill.exec.store.kudu.KuduRecordWriter.BigIntKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.BitKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.Decimal28DenseKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.Decimal38DenseKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.Float4KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.Float8KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.IntKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableBigIntKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableBitKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableDecimal28DenseKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableDecimal38DenseKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableFloat4KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableFloat8KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableIntKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableTimeStampKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableUInt8KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableVar16CharKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableVarBinaryKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableVarCharKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.NullableVarDecimalKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.TimeStampKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.UInt8KuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.Var16CharKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.VarBinaryKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.VarCharKuduConverter, org.apache.drill.exec.store.kudu.KuduRecordWriter.VarDecimalKuduConverter

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	abort()
void	cleanup()
void	endRecord()
void	init(Map<String,String> writerOptions)
void	startRecord()
void	updateSchema(VectorAccessible batch)

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

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

Constructor Detail

KuduRecordWriterImpl

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

Method Detail

init

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

Throws:

IOException

updateSchema

public void updateSchema(VectorAccessible batch)
                  throws IOException

Throws:

IOException

startRecord

public void startRecord()
                 throws IOException

Throws:

IOException

endRecord

public void endRecord()
               throws IOException

Throws:

IOException

abort

public void abort()
           throws IOException

Throws:

IOException

cleanup

public void cleanup()
             throws IOException

Throws:

IOException