org.apache.hadoop.mapreduce
Class RecordWriter<K,V>
java.lang.Object
org.apache.hadoop.mapreduce.RecordWriter<K,V>
@InterfaceAudience.Public
@InterfaceStability.Stable
public abstract class RecordWriter<K,V>
- extends Object
RecordWriter
writes the output <key, value> pairs
to an output file.
RecordWriter
implementations write the job outputs to the
FileSystem
.
- See Also:
OutputFormat
Method Summary |
abstract void |
close(TaskAttemptContext context)
Close this RecordWriter to future operations. |
abstract void |
write(K key,
V value)
Writes a key/value pair. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RecordWriter
public RecordWriter()
write
public abstract void write(K key,
V value)
throws IOException,
InterruptedException
- Writes a key/value pair.
- Parameters:
key
- the key to write.value
- the value to write.
- Throws:
IOException
InterruptedException
close
public abstract void close(TaskAttemptContext context)
throws IOException,
InterruptedException
- Close this
RecordWriter
to future operations.
- Parameters:
context
- the context of the task
- Throws:
IOException
InterruptedException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.