Class TextRecordWriter
java.lang.Object
org.apache.drill.exec.store.AbstractRecordWriter
org.apache.drill.exec.store.StringOutputRecordWriter
org.apache.drill.exec.store.easy.text.writer.TextRecordWriter
- All Implemented Interfaces:
RecordWriter
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.drill.exec.store.StringOutputRecordWriter
StringOutputRecordWriter.BigIntStringFieldConverter, StringOutputRecordWriter.BitStringFieldConverter, StringOutputRecordWriter.DateStringFieldConverter, StringOutputRecordWriter.Decimal18StringFieldConverter, StringOutputRecordWriter.Decimal28DenseStringFieldConverter, StringOutputRecordWriter.Decimal28SparseStringFieldConverter, StringOutputRecordWriter.Decimal38DenseStringFieldConverter, StringOutputRecordWriter.Decimal38SparseStringFieldConverter, StringOutputRecordWriter.Decimal9StringFieldConverter, StringOutputRecordWriter.Float4StringFieldConverter, StringOutputRecordWriter.Float8StringFieldConverter, StringOutputRecordWriter.IntervalDayStringFieldConverter, StringOutputRecordWriter.IntervalStringFieldConverter, StringOutputRecordWriter.IntervalYearStringFieldConverter, StringOutputRecordWriter.IntStringFieldConverter, StringOutputRecordWriter.NullableBigIntStringFieldConverter, StringOutputRecordWriter.NullableBitStringFieldConverter, StringOutputRecordWriter.NullableDateStringFieldConverter, StringOutputRecordWriter.NullableDecimal18StringFieldConverter, StringOutputRecordWriter.NullableDecimal28DenseStringFieldConverter, StringOutputRecordWriter.NullableDecimal28SparseStringFieldConverter, StringOutputRecordWriter.NullableDecimal38DenseStringFieldConverter, StringOutputRecordWriter.NullableDecimal38SparseStringFieldConverter, StringOutputRecordWriter.NullableDecimal9StringFieldConverter, StringOutputRecordWriter.NullableFloat4StringFieldConverter, StringOutputRecordWriter.NullableFloat8StringFieldConverter, StringOutputRecordWriter.NullableIntervalDayStringFieldConverter, StringOutputRecordWriter.NullableIntervalStringFieldConverter, StringOutputRecordWriter.NullableIntervalYearStringFieldConverter, StringOutputRecordWriter.NullableIntStringFieldConverter, StringOutputRecordWriter.NullableSmallIntStringFieldConverter, StringOutputRecordWriter.NullableTimeStampStringFieldConverter, StringOutputRecordWriter.NullableTimeStringFieldConverter, StringOutputRecordWriter.NullableTinyIntStringFieldConverter, StringOutputRecordWriter.NullableUInt1StringFieldConverter, StringOutputRecordWriter.NullableUInt2StringFieldConverter, StringOutputRecordWriter.NullableUInt4StringFieldConverter, StringOutputRecordWriter.NullableUInt8StringFieldConverter, StringOutputRecordWriter.NullableVar16CharStringFieldConverter, StringOutputRecordWriter.NullableVarBinaryStringFieldConverter, StringOutputRecordWriter.NullableVarCharStringFieldConverter, StringOutputRecordWriter.NullableVarDecimalStringFieldConverter, StringOutputRecordWriter.RepeatedBigIntStringFieldConverter, StringOutputRecordWriter.RepeatedBitStringFieldConverter, StringOutputRecordWriter.RepeatedDateStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal18StringFieldConverter, StringOutputRecordWriter.RepeatedDecimal28DenseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal28SparseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal38DenseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal38SparseStringFieldConverter, StringOutputRecordWriter.RepeatedDecimal9StringFieldConverter, StringOutputRecordWriter.RepeatedFloat4StringFieldConverter, StringOutputRecordWriter.RepeatedFloat8StringFieldConverter, StringOutputRecordWriter.RepeatedIntervalDayStringFieldConverter, StringOutputRecordWriter.RepeatedIntervalStringFieldConverter, StringOutputRecordWriter.RepeatedIntervalYearStringFieldConverter, StringOutputRecordWriter.RepeatedIntStringFieldConverter, StringOutputRecordWriter.RepeatedSmallIntStringFieldConverter, StringOutputRecordWriter.RepeatedTimeStampStringFieldConverter, StringOutputRecordWriter.RepeatedTimeStringFieldConverter, StringOutputRecordWriter.RepeatedTinyIntStringFieldConverter, StringOutputRecordWriter.RepeatedUInt1StringFieldConverter, StringOutputRecordWriter.RepeatedUInt2StringFieldConverter, StringOutputRecordWriter.RepeatedUInt4StringFieldConverter, StringOutputRecordWriter.RepeatedUInt8StringFieldConverter, StringOutputRecordWriter.RepeatedVar16CharStringFieldConverter, StringOutputRecordWriter.RepeatedVarBinaryStringFieldConverter, StringOutputRecordWriter.RepeatedVarCharStringFieldConverter, StringOutputRecordWriter.RepeatedVarDecimalStringFieldConverter, StringOutputRecordWriter.SmallIntStringFieldConverter, StringOutputRecordWriter.TimeStampStringFieldConverter, StringOutputRecordWriter.TimeStringFieldConverter, StringOutputRecordWriter.TinyIntStringFieldConverter, StringOutputRecordWriter.UInt1StringFieldConverter, StringOutputRecordWriter.UInt2StringFieldConverter, StringOutputRecordWriter.UInt4StringFieldConverter, StringOutputRecordWriter.UInt8StringFieldConverter, StringOutputRecordWriter.Var16CharStringFieldConverter, StringOutputRecordWriter.VarBinaryStringFieldConverter, StringOutputRecordWriter.VarCharStringFieldConverter, StringOutputRecordWriter.VarDecimalStringFieldConverter
-
Constructor Summary
ConstructorDescriptionTextRecordWriter
(BufferAllocator allocator, StorageStrategy storageStrategy, org.apache.hadoop.conf.Configuration fsConf) -
Method Summary
Modifier and TypeMethodDescriptionvoid
abort()
void
void
cleanup()
void
Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.getNewMapConverter
(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) void
Initialize the writer.void
startNewSchema
(BatchSchema schema) void
Called before starting writing fields in a record.Methods inherited from class org.apache.drill.exec.store.StringOutputRecordWriter
getNewBigIntConverter, getNewBitConverter, getNewDateConverter, getNewDecimal18Converter, getNewDecimal28DenseConverter, getNewDecimal28SparseConverter, getNewDecimal38DenseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewFloat4Converter, getNewFloat8Converter, getNewIntConverter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewNullableBigIntConverter, getNewNullableBitConverter, getNewNullableDateConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38DenseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableFloat4Converter, getNewNullableFloat8Converter, getNewNullableIntConverter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTimeStampConverter, getNewNullableTinyIntConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, getNewNullableVarBinaryConverter, getNewNullableVarCharConverter, getNewNullableVarDecimalConverter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewSmallIntConverter, getNewTimeConverter, getNewTimeStampConverter, getNewTinyIntConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUInt8Converter, getNewVar16CharConverter, getNewVarBinaryConverter, getNewVarCharConverter, getNewVarDecimalConverter, updateSchema
Methods inherited from class org.apache.drill.exec.store.AbstractRecordWriter
checkForNewPartition, getNewDictConverter, getNewRepeatedDictConverter, getNewUnionConverter, newPartition, postProcessing, setPartitionVector, supportsField
-
Constructor Details
-
TextRecordWriter
public TextRecordWriter(BufferAllocator allocator, StorageStrategy storageStrategy, org.apache.hadoop.conf.Configuration fsConf)
-
-
Method Details
-
init
Description copied from interface:RecordWriter
Initialize the writer.- Parameters:
writerOptions
- Contains key, value pair of settings.- Throws:
IOException
-
startNewSchema
- Specified by:
startNewSchema
in classStringOutputRecordWriter
- Throws:
IOException
-
addField
- Specified by:
addField
in classStringOutputRecordWriter
-
startRecord
Description copied from interface:RecordWriter
Called before starting writing fields in a record.- Throws:
IOException
-
endRecord
Description copied from interface:RecordWriter
Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.- 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 classStringOutputRecordWriter
-
getNewRepeatedMapConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedMapConverter(int fieldId, String fieldName, FieldReader reader) - Specified by:
getNewRepeatedMapConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedMapConverter
in classStringOutputRecordWriter
-
getNewRepeatedListConverter
public EventBasedRecordWriter.FieldConverter getNewRepeatedListConverter(int fieldId, String fieldName, FieldReader reader) - Specified by:
getNewRepeatedListConverter
in interfaceRecordWriter
- Overrides:
getNewRepeatedListConverter
in classStringOutputRecordWriter
-
cleanup
- Specified by:
cleanup
in interfaceRecordWriter
- Overrides:
cleanup
in classStringOutputRecordWriter
- Throws:
IOException
-
abort
- Throws:
IOException
-