org.apache.hadoop.hbase.mapreduce
Class PutSortReducer
java.lang.Object
org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable,Put,ImmutableBytesWritable,KeyValue>
org.apache.hadoop.hbase.mapreduce.PutSortReducer
public class PutSortReducer
- extends org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable,Put,ImmutableBytesWritable,KeyValue>
Emits sorted Puts.
Reads in all Puts from passed Iterator, sorts them, then emits
Puts in sorted order. If lots of columns per row, it will use lots of
memory sorting.
- See Also:
HFileOutputFormat
,
KeyValueSortReducer
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer |
org.apache.hadoop.mapreduce.Reducer.Context |
Methods inherited from class org.apache.hadoop.mapreduce.Reducer |
cleanup, run, setup |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PutSortReducer
public PutSortReducer()
reduce
protected void reduce(ImmutableBytesWritable row,
Iterable<Put> puts,
org.apache.hadoop.mapreduce.Reducer.Context context)
throws IOException,
InterruptedException
- Overrides:
reduce
in class org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable,Put,ImmutableBytesWritable,KeyValue>
- Throws:
IOException
InterruptedException
Copyright © 2011 The Apache Software Foundation. All Rights Reserved.