org.apache.hadoop.mapreduce

类 RecordWriter<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<K,V>

直接已知子类:

DBOutputFormat.DBRecordWriter, FilterOutputFormat.FilterRecordWriter, TextOutputFormat.LineRecordWriter

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.

另请参阅:

OutputFormat

构造器概要

构造器

构造器和说明
RecordWriter()

方法概要

方法

限定符和类型	方法和说明
abstract void	close(TaskAttemptContext context) Close this RecordWriter to future operations.
abstract void	write(K key, V value) Writes a key/value pair.

从类继承的方法 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.

参数:

key - the key to write.

value - the value to write.

抛出:

IOException

InterruptedException

close

public abstract void close(TaskAttemptContext context)
                    throws IOException,
                           InterruptedException

Close this RecordWriter to future operations.

参数:

context - the context of the task

抛出:

IOException

InterruptedException