Package org.apache.drill.exec.store

Interface RecordWriter

All Known Implementing Classes:

AbstractRecordWriter, GoogleSheetsBatchInsertWriter, GoogleSheetsBatchWriter, JdbcRecordWriter, JdbcTableModifyWriter, JSONOutputRecordWriter, JsonRecordWriter, KuduRecordWriter, KuduRecordWriterImpl, ParquetOutputRecordWriter, ParquetRecordWriter, SplunkBatchInsertWriter, SplunkBatchWriter, StringOutputRecordWriter, TextRecordWriter

public interface RecordWriter

RecordWriter interface.

Method Summary

Modifier and Type	Method	Description
void	abort()
void	checkForNewPartition(int index)	Check if the writer should start a new partition, and if so, start a new partition
void	cleanup()
void	endRecord()	Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.
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	getNewDateConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDecimal18Converter(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	getNewDecimal28SparseConverter(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	getNewDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDecimal9Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDictConverter(int fieldId, String fieldName, FieldReader reader)
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	getNewIntervalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewMapConverter(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	getNewNullableDateConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableDecimal18Converter(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	getNewNullableDecimal28SparseConverter(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	getNewNullableDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableDecimal9Converter(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	getNewNullableIntervalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableSmallIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableTimeConverter(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	getNewNullableTinyIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableUInt1Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableUInt2Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableUInt4Converter(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	getNewRepeatedBigIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedBitConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDateConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal18Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDecimal9Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedDictConverter(int fieldId, String fieldName, FieldReader reader)
EventBasedRecordWriter.FieldConverter	getNewRepeatedFloat4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedFloat8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedIntervalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedListConverter(int fieldId, String fieldName, FieldReader reader)
EventBasedRecordWriter.FieldConverter	getNewRepeatedMapConverter(int fieldId, String fieldName, FieldReader reader)
EventBasedRecordWriter.FieldConverter	getNewRepeatedSmallIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedTimeConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedTimeStampConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedTinyIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedUInt1Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedUInt2Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedUInt4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedUInt8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedVar16CharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedVarCharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewRepeatedVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewSmallIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewTimeConverter(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	getNewTinyIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewUInt1Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewUInt2Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewUInt4Converter(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	getNewUnionConverter(int fieldId, String fieldName, FieldReader reader)
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	init(Map<String,String> writerOptions)	Initialize the writer.
void	postProcessing()	Called after adding all the records to perform any post processing related tasks
void	startRecord()	Called before starting writing fields in a record.
boolean	supportsField(MaterializedField field)	Checks whether this writer supports writing of the given field.
void	updateSchema(VectorAccessible batch)	Update the schema in RecordWriter.

Method Details

init

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

Initialize the writer.

Parameters:

writerOptions - Contains key, value pair of settings.

Throws:

IOException

updateSchema

void updateSchema(VectorAccessible batch)
           throws IOException

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

Parameters:

batch -

Throws:

IOException

checkForNewPartition

void checkForNewPartition(int index)

Check if the writer should start a new partition, and if so, start a new partition

startRecord

void startRecord()
          throws IOException

Called before starting writing fields in a record.

Throws:

IOException

getNewMapConverter

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

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

getNewUnionConverter

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

getNewRepeatedMapConverter

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

getNewRepeatedListConverter

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

getNewDictConverter

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

getNewRepeatedDictConverter

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

getNewNullableTinyIntConverter

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

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

getNewTinyIntConverter

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

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

getNewRepeatedTinyIntConverter

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

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

getNewNullableUInt1Converter

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

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

getNewUInt1Converter

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

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

getNewRepeatedUInt1Converter

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

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

getNewNullableUInt2Converter

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

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

getNewUInt2Converter

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

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

getNewRepeatedUInt2Converter

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

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

getNewNullableSmallIntConverter

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

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

getNewSmallIntConverter

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

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

getNewRepeatedSmallIntConverter

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

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

getNewNullableIntConverter

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

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

getNewIntConverter

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

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

getNewRepeatedIntConverter

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

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

getNewNullableUInt4Converter

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

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

getNewUInt4Converter

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

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

getNewRepeatedUInt4Converter

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

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

getNewNullableFloat4Converter

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

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

getNewFloat4Converter

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

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

getNewRepeatedFloat4Converter

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

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

getNewNullableTimeConverter

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

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

getNewTimeConverter

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

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

getNewRepeatedTimeConverter

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

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

getNewNullableIntervalYearConverter

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

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

getNewIntervalYearConverter

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

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

getNewRepeatedIntervalYearConverter

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

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

getNewNullableDecimal9Converter

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

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

getNewDecimal9Converter

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

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

getNewRepeatedDecimal9Converter

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

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

getNewNullableBigIntConverter

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

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

getNewBigIntConverter

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

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

getNewRepeatedBigIntConverter

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

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

getNewNullableUInt8Converter

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

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

getNewUInt8Converter

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

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

getNewRepeatedUInt8Converter

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

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

getNewNullableFloat8Converter

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

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

getNewFloat8Converter

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

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

getNewRepeatedFloat8Converter

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

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

getNewNullableDateConverter

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

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

getNewDateConverter

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

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

getNewRepeatedDateConverter

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

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

getNewNullableTimeStampConverter

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

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

getNewTimeStampConverter

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

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

getNewRepeatedTimeStampConverter

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

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

getNewNullableDecimal18Converter

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

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

getNewDecimal18Converter

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

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

getNewRepeatedDecimal18Converter

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

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

getNewNullableIntervalDayConverter

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

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

getNewIntervalDayConverter

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

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

getNewRepeatedIntervalDayConverter

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

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

getNewNullableIntervalConverter

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

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

getNewIntervalConverter

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

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

getNewRepeatedIntervalConverter

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

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

getNewNullableDecimal28DenseConverter

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

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

getNewDecimal28DenseConverter

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

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

getNewRepeatedDecimal28DenseConverter

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

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

getNewNullableDecimal38DenseConverter

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

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

getNewDecimal38DenseConverter

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

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

getNewRepeatedDecimal38DenseConverter

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

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

getNewNullableDecimal38SparseConverter

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

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

getNewDecimal38SparseConverter

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

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

getNewRepeatedDecimal38SparseConverter

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

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

getNewNullableDecimal28SparseConverter

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

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

getNewDecimal28SparseConverter

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

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

getNewRepeatedDecimal28SparseConverter

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

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

getNewNullableVarBinaryConverter

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

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

getNewVarBinaryConverter

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

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

getNewRepeatedVarBinaryConverter

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

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

getNewNullableVarCharConverter

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

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

getNewVarCharConverter

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

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

getNewRepeatedVarCharConverter

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

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

getNewNullableVar16CharConverter

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

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

getNewVar16CharConverter

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

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

getNewRepeatedVar16CharConverter

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

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

getNewNullableVarDecimalConverter

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

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

getNewVarDecimalConverter

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

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

getNewRepeatedVarDecimalConverter

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

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

getNewNullableBitConverter

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

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

getNewBitConverter

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

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

getNewRepeatedBitConverter

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

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

endRecord

void endRecord()
        throws IOException

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

Throws:

IOException

postProcessing

void postProcessing()
             throws IOException

Called after adding all the records to perform any post processing related tasks

Throws:

IOException

abort

void abort()
    throws IOException

Throws:

IOException

cleanup

void cleanup()
      throws IOException

Throws:

IOException

supportsField

boolean supportsField(MaterializedField field)

Checks whether this writer supports writing of the given field.