org.apache.hadoop.mapreduce.lib.output

类 FilterOutputFormat.FilterRecordWriter<K,V>

java.lang.Object

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

org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat.FilterRecordWriter<K,V>

封闭类:

FilterOutputFormat<K,V>

public static class FilterOutputFormat.FilterRecordWriter<K,V>
extends RecordWriter<K,V>

FilterRecordWriter is a convenience wrapper class that extends the RecordWriter.

字段概要

字段

限定符和类型	字段和说明
protected RecordWriter<K,V>	rawWriter

构造器概要

构造器

构造器和说明
FilterOutputFormat.FilterRecordWriter()
FilterOutputFormat.FilterRecordWriter(RecordWriter<K,V> rwriter)

方法概要

方法

限定符和类型	方法和说明
void	close(TaskAttemptContext context) Close this RecordWriter to future operations.
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

字段详细资料

rawWriter

protected RecordWriter<K,V> rawWriter

构造器详细资料

FilterOutputFormat.FilterRecordWriter

public FilterOutputFormat.FilterRecordWriter()

FilterOutputFormat.FilterRecordWriter

public FilterOutputFormat.FilterRecordWriter(RecordWriter<K,V> rwriter)

方法详细资料

write

public void write(K key,
         V value)
           throws IOException,
                  InterruptedException

从类复制的说明: RecordWriter

Writes a key/value pair.

指定者:

write 在类中 RecordWriter<K,V>

参数:

key - the key to write.

value - the value to write.

抛出:

IOException

InterruptedException

close

public void close(TaskAttemptContext context)
           throws IOException,
                  InterruptedException

从类复制的说明: RecordWriter

Close this RecordWriter to future operations.

指定者:

close 在类中 RecordWriter<K,V>

参数:

context - the context of the task

抛出:

IOException

InterruptedException