类 org.apache.hadoop.mapreduce.RecordWriter
的使用

使用RecordWriter的程序包

程序包	说明
org.apache.hadoop.mapred	A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner.
org.apache.hadoop.mapreduce
org.apache.hadoop.mapreduce.lib.db
org.apache.hadoop.mapreduce.lib.output

org.apache.hadoop.mapred中RecordWriter的使用

参数类型为RecordWriter的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
protected static <INKEY,INVALUE,OUTKEY,OUTVALUE> Reducer.Context	Task.createReduceContext(Reducer<INKEY,INVALUE,OUTKEY,OUTVALUE> reducer, Configuration job, TaskAttemptID taskId, RawKeyValueIterator rIter, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<OUTKEY,OUTVALUE> output, OutputCommitter committer, StatusReporter reporter, RawComparator<INKEY> comparator, Class<INKEY> keyClass, Class<INVALUE> valueClass)

org.apache.hadoop.mapreduce中RecordWriter的使用

返回RecordWriter的org.apache.hadoop.mapreduce中的方法

限定符和类型	方法和说明
abstract RecordWriter<K,V>	OutputFormat.getRecordWriter(TaskAttemptContext context) Get the RecordWriter for the given task.

参数类型为RecordWriter的org.apache.hadoop.mapreduce中的构造器

构造器和说明
MapContext(Configuration conf, TaskAttemptID taskid, RecordReader<KEYIN,VALUEIN> reader, RecordWriter<KEYOUT,VALUEOUT> writer, OutputCommitter committer, StatusReporter reporter, InputSplit split)
Mapper.Context(Configuration conf, TaskAttemptID taskid, RecordReader<KEYIN,VALUEIN> reader, RecordWriter<KEYOUT,VALUEOUT> writer, OutputCommitter committer, StatusReporter reporter, InputSplit split)
ReduceContext(Configuration conf, TaskAttemptID taskid, RawKeyValueIterator input, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter, RawComparator<KEYIN> comparator, Class<KEYIN> keyClass, Class<VALUEIN> valueClass)
Reducer.Context(Configuration conf, TaskAttemptID taskid, RawKeyValueIterator input, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter, RawComparator<KEYIN> comparator, Class<KEYIN> keyClass, Class<VALUEIN> valueClass)
TaskInputOutputContext(Configuration conf, TaskAttemptID taskid, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter)

org.apache.hadoop.mapreduce.lib.db中RecordWriter的使用

org.apache.hadoop.mapreduce.lib.db中RecordWriter的子类

限定符和类型	类和说明
class	DBOutputFormat.DBRecordWriter A RecordWriter that writes the reduce output to a SQL table

返回RecordWriter的org.apache.hadoop.mapreduce.lib.db中的方法

限定符和类型	方法和说明
RecordWriter<K,V>	DBOutputFormat.getRecordWriter(TaskAttemptContext context) Get the RecordWriter for the given task.

org.apache.hadoop.mapreduce.lib.output中RecordWriter的使用

org.apache.hadoop.mapreduce.lib.output中RecordWriter的子类

限定符和类型	类和说明
static class	FilterOutputFormat.FilterRecordWriter<K,V> FilterRecordWriter is a convenience wrapper class that extends the RecordWriter.
protected static class	TextOutputFormat.LineRecordWriter<K,V>

声明为RecordWriter的org.apache.hadoop.mapreduce.lib.output中的字段

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

返回RecordWriter的org.apache.hadoop.mapreduce.lib.output中的方法

限定符和类型	方法和说明
RecordWriter<K,V>	TextOutputFormat.getRecordWriter(TaskAttemptContext job)
RecordWriter<K,V>	SequenceFileOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<BytesWritable,BytesWritable>	SequenceFileAsBinaryOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	NullOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	LazyOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	FilterOutputFormat.getRecordWriter(TaskAttemptContext context)
abstract RecordWriter<K,V>	FileOutputFormat.getRecordWriter(TaskAttemptContext job)

参数类型为RecordWriter的org.apache.hadoop.mapreduce.lib.output中的构造器

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