Package org.apache.drill.exec.store
Class StringOutputRecordWriter
java.lang.Object
org.apache.drill.exec.store.AbstractRecordWriter
org.apache.drill.exec.store.StringOutputRecordWriter
- All Implemented Interfaces:
RecordWriter
- Direct Known Subclasses:
TextRecordWriter
Abstract implementation of RecordWriter interface which exposes interface:
startNewSchema(BatchSchema)
addField(int,String)
to output the data in string format instead of implementing addField for each type holder.
This is useful for text format writers such as CSV, TSV etc.
NB: Source code generated using FreeMarker template StringOutputRecordWriter.java-
Nested Class Summary
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract void
void
cleanup()
getNewBigIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewBitConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDateConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal18Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal28DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal28SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal38DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal38SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewDecimal9Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewFloat4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewFloat8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewIntervalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewIntervalDayConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewIntervalYearConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewMapConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableBigIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableBitConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDateConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal18Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal28DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal28SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal38DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal38SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableDecimal9Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableFloat4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableFloat8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableIntervalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableIntervalDayConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableIntervalYearConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableSmallIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableTimeConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableTimeStampConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableTinyIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableUInt1Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableUInt2Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableUInt4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableUInt8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableVar16CharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableVarBinaryConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableVarCharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewNullableVarDecimalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedBigIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedBitConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDateConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal18Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal28DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal28SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal38DenseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal38SparseConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedDecimal9Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedFloat4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedFloat8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedIntervalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedIntervalDayConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedIntervalYearConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedListConverter
(int fieldId, String fieldName, FieldReader reader) getNewRepeatedMapConverter
(int fieldId, String fieldName, FieldReader reader) getNewRepeatedSmallIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedTimeConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedTimeStampConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedTinyIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedUInt1Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedUInt2Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedUInt4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedUInt8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedVar16CharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedVarBinaryConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedVarCharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewRepeatedVarDecimalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewSmallIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewTimeConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewTimeStampConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewTinyIntConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewUInt1Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewUInt2Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewUInt4Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewUInt8Converter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewVar16CharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewVarBinaryConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewVarCharConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.getNewVarDecimalConverter
(int fieldId, String fieldName, FieldReader reader) Add the field value given invalueHolder
at the given column numberfieldId
.abstract void
startNewSchema
(BatchSchema schema) void
updateSchema
(VectorAccessible batch) Update the schema in RecordWriter.Methods inherited from class org.apache.drill.exec.store.AbstractRecordWriter
checkForNewPartition, getNewDictConverter, getNewRepeatedDictConverter, getNewUnionConverter, newPartition, postProcessing, setPartitionVector, supportsField
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.drill.exec.store.RecordWriter
abort, endRecord, init, startRecord
-
Constructor Details
-
StringOutputRecordWriter
-
-
Method Details
-
updateSchema
Description copied from interface:RecordWriter
Update the schema in RecordWriter. Called at least once before starting writing the records.- Throws:
IOException
-
getNewMapConverter
public EventBasedRecordWriter.FieldConverter getNewMapConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewMapConverter
in interfaceRecordWriter
- Overrides:
getNewMapConverter
in classAbstractRecordWriter
-
getNewRepeatedMapConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedMapConverter(int fieldId, String fieldName, FieldReader reader) - Specified by:
getNewRepeatedMapConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedMapConverter
in classAbstractRecordWriter
-
getNewRepeatedListConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedListConverter(int fieldId, String fieldName, FieldReader reader) - Specified by:
getNewRepeatedListConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedListConverter
in classAbstractRecordWriter
-
getNewNullableTinyIntConverter
public EventBasedRecordWriter.FieldConverter getNewNullableTinyIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableTinyIntConverter
in interfaceRecordWriter
- Overrides:
getNewNullableTinyIntConverter
in classAbstractRecordWriter
-
getNewTinyIntConverter
public EventBasedRecordWriter.FieldConverter getNewTinyIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewTinyIntConverter
in interfaceRecordWriter
- Overrides:
getNewTinyIntConverter
in classAbstractRecordWriter
-
getNewRepeatedTinyIntConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTinyIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedTinyIntConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedTinyIntConverter
in classAbstractRecordWriter
-
getNewNullableUInt1Converter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt1Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableUInt1Converter
in interfaceRecordWriter
- Overrides:
getNewNullableUInt1Converter
in classAbstractRecordWriter
-
getNewUInt1Converter
public EventBasedRecordWriter.FieldConverter getNewUInt1Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewUInt1Converter
in interfaceRecordWriter
- Overrides:
getNewUInt1Converter
in classAbstractRecordWriter
-
getNewRepeatedUInt1Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt1Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedUInt1Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedUInt1Converter
in classAbstractRecordWriter
-
getNewNullableUInt2Converter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt2Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableUInt2Converter
in interfaceRecordWriter
- Overrides:
getNewNullableUInt2Converter
in classAbstractRecordWriter
-
getNewUInt2Converter
public EventBasedRecordWriter.FieldConverter getNewUInt2Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewUInt2Converter
in interfaceRecordWriter
- Overrides:
getNewUInt2Converter
in classAbstractRecordWriter
-
getNewRepeatedUInt2Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt2Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedUInt2Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedUInt2Converter
in classAbstractRecordWriter
-
getNewNullableSmallIntConverter
public EventBasedRecordWriter.FieldConverter getNewNullableSmallIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableSmallIntConverter
in interfaceRecordWriter
- Overrides:
getNewNullableSmallIntConverter
in classAbstractRecordWriter
-
getNewSmallIntConverter
public EventBasedRecordWriter.FieldConverter getNewSmallIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewSmallIntConverter
in interfaceRecordWriter
- Overrides:
getNewSmallIntConverter
in classAbstractRecordWriter
-
getNewRepeatedSmallIntConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedSmallIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedSmallIntConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedSmallIntConverter
in classAbstractRecordWriter
-
getNewNullableIntConverter
public EventBasedRecordWriter.FieldConverter getNewNullableIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableIntConverter
in interfaceRecordWriter
- Overrides:
getNewNullableIntConverter
in classAbstractRecordWriter
-
getNewIntConverter
public EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewIntConverter
in interfaceRecordWriter
- Overrides:
getNewIntConverter
in classAbstractRecordWriter
-
getNewRepeatedIntConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedIntConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedIntConverter
in classAbstractRecordWriter
-
getNewNullableUInt4Converter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableUInt4Converter
in interfaceRecordWriter
- Overrides:
getNewNullableUInt4Converter
in classAbstractRecordWriter
-
getNewUInt4Converter
public EventBasedRecordWriter.FieldConverter getNewUInt4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewUInt4Converter
in interfaceRecordWriter
- Overrides:
getNewUInt4Converter
in classAbstractRecordWriter
-
getNewRepeatedUInt4Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedUInt4Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedUInt4Converter
in classAbstractRecordWriter
-
getNewNullableFloat4Converter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableFloat4Converter
in interfaceRecordWriter
- Overrides:
getNewNullableFloat4Converter
in classAbstractRecordWriter
-
getNewFloat4Converter
public EventBasedRecordWriter.FieldConverter getNewFloat4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewFloat4Converter
in interfaceRecordWriter
- Overrides:
getNewFloat4Converter
in classAbstractRecordWriter
-
getNewRepeatedFloat4Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedFloat4Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedFloat4Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedFloat4Converter
in classAbstractRecordWriter
-
getNewNullableTimeConverter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableTimeConverter
in interfaceRecordWriter
- Overrides:
getNewNullableTimeConverter
in classAbstractRecordWriter
-
getNewTimeConverter
public EventBasedRecordWriter.FieldConverter getNewTimeConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewTimeConverter
in interfaceRecordWriter
- Overrides:
getNewTimeConverter
in classAbstractRecordWriter
-
getNewRepeatedTimeConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTimeConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedTimeConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedTimeConverter
in classAbstractRecordWriter
-
getNewNullableIntervalYearConverter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalYearConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableIntervalYearConverter
in interfaceRecordWriter
- Overrides:
getNewNullableIntervalYearConverter
in classAbstractRecordWriter
-
getNewIntervalYearConverter
public EventBasedRecordWriter.FieldConverter getNewIntervalYearConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewIntervalYearConverter
in interfaceRecordWriter
- Overrides:
getNewIntervalYearConverter
in classAbstractRecordWriter
-
getNewRepeatedIntervalYearConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalYearConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedIntervalYearConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedIntervalYearConverter
in classAbstractRecordWriter
-
getNewNullableDecimal9Converter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal9Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal9Converter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal9Converter
in classAbstractRecordWriter
-
getNewDecimal9Converter
public EventBasedRecordWriter.FieldConverter getNewDecimal9Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal9Converter
in interfaceRecordWriter
- Overrides:
getNewDecimal9Converter
in classAbstractRecordWriter
-
getNewRepeatedDecimal9Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal9Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal9Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal9Converter
in classAbstractRecordWriter
-
getNewNullableBigIntConverter
public EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableBigIntConverter
in interfaceRecordWriter
- Overrides:
getNewNullableBigIntConverter
in classAbstractRecordWriter
-
getNewBigIntConverter
public EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewBigIntConverter
in interfaceRecordWriter
- Overrides:
getNewBigIntConverter
in classAbstractRecordWriter
-
getNewRepeatedBigIntConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedBigIntConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedBigIntConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedBigIntConverter
in classAbstractRecordWriter
-
getNewNullableUInt8Converter
public EventBasedRecordWriter.FieldConverter getNewNullableUInt8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableUInt8Converter
in interfaceRecordWriter
- Overrides:
getNewNullableUInt8Converter
in classAbstractRecordWriter
-
getNewUInt8Converter
public EventBasedRecordWriter.FieldConverter getNewUInt8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewUInt8Converter
in interfaceRecordWriter
- Overrides:
getNewUInt8Converter
in classAbstractRecordWriter
-
getNewRepeatedUInt8Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedUInt8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedUInt8Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedUInt8Converter
in classAbstractRecordWriter
-
getNewNullableFloat8Converter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableFloat8Converter
in interfaceRecordWriter
- Overrides:
getNewNullableFloat8Converter
in classAbstractRecordWriter
-
getNewFloat8Converter
public EventBasedRecordWriter.FieldConverter getNewFloat8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewFloat8Converter
in interfaceRecordWriter
- Overrides:
getNewFloat8Converter
in classAbstractRecordWriter
-
getNewRepeatedFloat8Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedFloat8Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedFloat8Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedFloat8Converter
in classAbstractRecordWriter
-
getNewNullableDateConverter
public EventBasedRecordWriter.FieldConverter getNewNullableDateConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDateConverter
in interfaceRecordWriter
- Overrides:
getNewNullableDateConverter
in classAbstractRecordWriter
-
getNewDateConverter
public EventBasedRecordWriter.FieldConverter getNewDateConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDateConverter
in interfaceRecordWriter
- Overrides:
getNewDateConverter
in classAbstractRecordWriter
-
getNewRepeatedDateConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDateConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDateConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDateConverter
in classAbstractRecordWriter
-
getNewNullableTimeStampConverter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeStampConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableTimeStampConverter
in interfaceRecordWriter
- Overrides:
getNewNullableTimeStampConverter
in classAbstractRecordWriter
-
getNewTimeStampConverter
public EventBasedRecordWriter.FieldConverter getNewTimeStampConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewTimeStampConverter
in interfaceRecordWriter
- Overrides:
getNewTimeStampConverter
in classAbstractRecordWriter
-
getNewRepeatedTimeStampConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedTimeStampConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedTimeStampConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedTimeStampConverter
in classAbstractRecordWriter
-
getNewNullableDecimal18Converter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal18Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal18Converter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal18Converter
in classAbstractRecordWriter
-
getNewDecimal18Converter
public EventBasedRecordWriter.FieldConverter getNewDecimal18Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal18Converter
in interfaceRecordWriter
- Overrides:
getNewDecimal18Converter
in classAbstractRecordWriter
-
getNewRepeatedDecimal18Converter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal18Converter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal18Converter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal18Converter
in classAbstractRecordWriter
-
getNewNullableIntervalDayConverter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalDayConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableIntervalDayConverter
in interfaceRecordWriter
- Overrides:
getNewNullableIntervalDayConverter
in classAbstractRecordWriter
-
getNewIntervalDayConverter
public EventBasedRecordWriter.FieldConverter getNewIntervalDayConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewIntervalDayConverter
in interfaceRecordWriter
- Overrides:
getNewIntervalDayConverter
in classAbstractRecordWriter
-
getNewRepeatedIntervalDayConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalDayConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedIntervalDayConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedIntervalDayConverter
in classAbstractRecordWriter
-
getNewNullableIntervalConverter
public EventBasedRecordWriter.FieldConverter getNewNullableIntervalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableIntervalConverter
in interfaceRecordWriter
- Overrides:
getNewNullableIntervalConverter
in classAbstractRecordWriter
-
getNewIntervalConverter
public EventBasedRecordWriter.FieldConverter getNewIntervalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewIntervalConverter
in interfaceRecordWriter
- Overrides:
getNewIntervalConverter
in classAbstractRecordWriter
-
getNewRepeatedIntervalConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedIntervalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedIntervalConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedIntervalConverter
in classAbstractRecordWriter
-
getNewNullableDecimal28DenseConverter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal28DenseConverter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal28DenseConverter
in classAbstractRecordWriter
-
getNewDecimal28DenseConverter
public EventBasedRecordWriter.FieldConverter getNewDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal28DenseConverter
in interfaceRecordWriter
- Overrides:
getNewDecimal28DenseConverter
in classAbstractRecordWriter
-
getNewRepeatedDecimal28DenseConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal28DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal28DenseConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal28DenseConverter
in classAbstractRecordWriter
-
getNewNullableDecimal38DenseConverter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal38DenseConverter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal38DenseConverter
in classAbstractRecordWriter
-
getNewDecimal38DenseConverter
public EventBasedRecordWriter.FieldConverter getNewDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal38DenseConverter
in interfaceRecordWriter
- Overrides:
getNewDecimal38DenseConverter
in classAbstractRecordWriter
-
getNewRepeatedDecimal38DenseConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal38DenseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal38DenseConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal38DenseConverter
in classAbstractRecordWriter
-
getNewNullableDecimal38SparseConverter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal38SparseConverter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal38SparseConverter
in classAbstractRecordWriter
-
getNewDecimal38SparseConverter
public EventBasedRecordWriter.FieldConverter getNewDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal38SparseConverter
in interfaceRecordWriter
- Overrides:
getNewDecimal38SparseConverter
in classAbstractRecordWriter
-
getNewRepeatedDecimal38SparseConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal38SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal38SparseConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal38SparseConverter
in classAbstractRecordWriter
-
getNewNullableDecimal28SparseConverter
public EventBasedRecordWriter.FieldConverter getNewNullableDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableDecimal28SparseConverter
in interfaceRecordWriter
- Overrides:
getNewNullableDecimal28SparseConverter
in classAbstractRecordWriter
-
getNewDecimal28SparseConverter
public EventBasedRecordWriter.FieldConverter getNewDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewDecimal28SparseConverter
in interfaceRecordWriter
- Overrides:
getNewDecimal28SparseConverter
in classAbstractRecordWriter
-
getNewRepeatedDecimal28SparseConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedDecimal28SparseConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedDecimal28SparseConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedDecimal28SparseConverter
in classAbstractRecordWriter
-
getNewNullableVarBinaryConverter
public EventBasedRecordWriter.FieldConverter getNewNullableVarBinaryConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableVarBinaryConverter
in interfaceRecordWriter
- Overrides:
getNewNullableVarBinaryConverter
in classAbstractRecordWriter
-
getNewVarBinaryConverter
public EventBasedRecordWriter.FieldConverter getNewVarBinaryConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewVarBinaryConverter
in interfaceRecordWriter
- Overrides:
getNewVarBinaryConverter
in classAbstractRecordWriter
-
getNewRepeatedVarBinaryConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarBinaryConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedVarBinaryConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedVarBinaryConverter
in classAbstractRecordWriter
-
getNewNullableVarCharConverter
public EventBasedRecordWriter.FieldConverter getNewNullableVarCharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableVarCharConverter
in interfaceRecordWriter
- Overrides:
getNewNullableVarCharConverter
in classAbstractRecordWriter
-
getNewVarCharConverter
public EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewVarCharConverter
in interfaceRecordWriter
- Overrides:
getNewVarCharConverter
in classAbstractRecordWriter
-
getNewRepeatedVarCharConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarCharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedVarCharConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedVarCharConverter
in classAbstractRecordWriter
-
getNewNullableVar16CharConverter
public EventBasedRecordWriter.FieldConverter getNewNullableVar16CharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableVar16CharConverter
in interfaceRecordWriter
- Overrides:
getNewNullableVar16CharConverter
in classAbstractRecordWriter
-
getNewVar16CharConverter
public EventBasedRecordWriter.FieldConverter getNewVar16CharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewVar16CharConverter
in interfaceRecordWriter
- Overrides:
getNewVar16CharConverter
in classAbstractRecordWriter
-
getNewRepeatedVar16CharConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVar16CharConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedVar16CharConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedVar16CharConverter
in classAbstractRecordWriter
-
getNewNullableVarDecimalConverter
public EventBasedRecordWriter.FieldConverter getNewNullableVarDecimalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableVarDecimalConverter
in interfaceRecordWriter
- Overrides:
getNewNullableVarDecimalConverter
in classAbstractRecordWriter
-
getNewVarDecimalConverter
public EventBasedRecordWriter.FieldConverter getNewVarDecimalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewVarDecimalConverter
in interfaceRecordWriter
- Overrides:
getNewVarDecimalConverter
in classAbstractRecordWriter
-
getNewRepeatedVarDecimalConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedVarDecimalConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedVarDecimalConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedVarDecimalConverter
in classAbstractRecordWriter
-
getNewNullableBitConverter
public EventBasedRecordWriter.FieldConverter getNewNullableBitConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewNullableBitConverter
in interfaceRecordWriter
- Overrides:
getNewNullableBitConverter
in classAbstractRecordWriter
-
getNewBitConverter
public EventBasedRecordWriter.FieldConverter getNewBitConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewBitConverter
in interfaceRecordWriter
- Overrides:
getNewBitConverter
in classAbstractRecordWriter
-
getNewRepeatedBitConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedBitConverter(int fieldId, String fieldName, FieldReader reader) Description copied from interface:RecordWriter
Add the field value given invalueHolder
at the given column numberfieldId
.- Specified by:
getNewRepeatedBitConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedBitConverter
in classAbstractRecordWriter
-
cleanup
- Throws:
IOException
-
startNewSchema
- Throws:
IOException
-
addField
- Throws:
IOException
-