public abstract class AbstractRecordWriter extends Object implements RecordWriter
Constructor and Description |
---|
AbstractRecordWriter() |
Modifier and Type | Method and Description |
---|---|
void |
checkForNewPartition(int index)
Check if the writer should start a new partition, and if so, start a new partition
|
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 . |
protected boolean |
newPartition(int index) |
void |
postProcessing()
Called after adding all the records to perform any post processing related tasks
|
protected void |
setPartitionVector(BitVector newPartitionVector) |
boolean |
supportsField(MaterializedField field)
Checks whether this writer supports writing of the given field.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
abort, cleanup, endRecord, init, startRecord, updateSchema
protected void setPartitionVector(BitVector newPartitionVector)
protected boolean newPartition(int index)
public void checkForNewPartition(int index)
RecordWriter
checkForNewPartition
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewMapConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewMapConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewUnionConverter(int fieldId, String fieldName, FieldReader reader)
getNewUnionConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedMapConverter(int fieldId, String fieldName, FieldReader reader)
getNewRepeatedMapConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedListConverter(int fieldId, String fieldName, FieldReader reader)
getNewRepeatedListConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDictConverter(int fieldId, String fieldName, FieldReader reader)
getNewDictConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDictConverter(int fieldId, String fieldName, FieldReader reader)
getNewRepeatedDictConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTinyIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTinyIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewTinyIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTinyIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTinyIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedTinyIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt1Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableUInt1Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewUInt1Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewUInt1Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt1Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedUInt1Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt2Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableUInt2Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewUInt2Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewUInt2Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt2Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedUInt2Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableSmallIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableSmallIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewSmallIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewSmallIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedSmallIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedSmallIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableUInt4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewUInt4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewUInt4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedUInt4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableFloat4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewFloat4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewFloat4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedFloat4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedFloat4Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTimeConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewTimeConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTimeConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTimeConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedTimeConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableIntervalYearConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewIntervalYearConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalYearConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedIntervalYearConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal9Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal9Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal9Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal9Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal9Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal9Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableBigIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewBigIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedBigIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedBigIntConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableUInt8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewUInt8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewUInt8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedUInt8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableFloat8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewFloat8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewFloat8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedFloat8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedFloat8Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDateConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDateConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDateConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDateConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDateConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDateConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeStampConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTimeStampConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewTimeStampConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTimeStampConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTimeStampConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedTimeStampConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal18Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal18Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal18Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal18Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal18Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal18Converter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableIntervalDayConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewIntervalDayConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalDayConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedIntervalDayConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableIntervalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewIntervalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewIntervalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedIntervalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal28DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal28DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal28DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal38DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal38DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal38DenseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal38SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal38SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal38SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDecimal28SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDecimal28SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedDecimal28SparseConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVarBinaryConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVarBinaryConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedVarBinaryConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVarCharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVarCharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVarCharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarCharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedVarCharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVar16CharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVar16CharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewVar16CharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVar16CharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVar16CharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedVar16CharConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVarDecimalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVarDecimalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedVarDecimalConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableBitConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableBitConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewBitConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewBitConverter
in interface RecordWriter
public EventBasedRecordWriter.FieldConverter getNewRepeatedBitConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewRepeatedBitConverter
in interface RecordWriter
public void postProcessing() throws IOException
RecordWriter
postProcessing
in interface RecordWriter
IOException
public boolean supportsField(MaterializedField field)
RecordWriter
supportsField
in interface RecordWriter
Copyright © 1970 The Apache Software Foundation. All rights reserved.