public class RecordReaderConverter extends Object
RecordReader
to one RecordWriter
,
or from one SequenceRecordReader
to one SequenceRecordWriter
Modifier and Type | Method and Description |
---|---|
static void |
convert(RecordReader reader,
RecordWriter writer)
Write all values from the specified record reader to the specified record writer.
|
static void |
convert(RecordReader reader,
RecordWriter writer,
boolean closeOnCompletion)
Write all values from the specified record reader to the specified record writer.
|
static void |
convert(SequenceRecordReader reader,
SequenceRecordWriter writer)
Write all sequences from the specified sequence record reader to the specified sequence record writer.
|
static void |
convert(SequenceRecordReader reader,
SequenceRecordWriter writer,
boolean closeOnCompletion)
Write all sequences from the specified sequence record reader to the specified sequence record writer.
|
public static void convert(RecordReader reader, RecordWriter writer) throws IOException
reader
- Record reader (source of data)writer
- Record writer (location to write data)IOException
- If underlying reader/writer throws an exceptionpublic static void convert(RecordReader reader, RecordWriter writer, boolean closeOnCompletion) throws IOException
reader
- Record reader (source of data)writer
- Record writer (location to write data)closeOnCompletion
- if true: close the record writer once complete, via RecordWriter.close()
IOException
- If underlying reader/writer throws an exceptionpublic static void convert(SequenceRecordReader reader, SequenceRecordWriter writer) throws IOException
reader
- Sequence record reader (source of data)writer
- Sequence record writer (location to write data)IOException
- If underlying reader/writer throws an exceptionpublic static void convert(SequenceRecordReader reader, SequenceRecordWriter writer, boolean closeOnCompletion) throws IOException
reader
- Sequence record reader (source of data)writer
- Sequence record writer (location to write data)closeOnCompletion
- if true: close the record writer once complete, via SequenceRecordWriter.close()
IOException
- If underlying reader/writer throws an exceptionCopyright © 2020. All rights reserved.