1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.mapred;
20
21 import java.io.IOException;
22 import java.util.Iterator;
23
24 import org.apache.commons.logging.Log;
25 import org.apache.commons.logging.LogFactory;
26 import org.apache.hadoop.hbase.classification.InterfaceAudience;
27 import org.apache.hadoop.hbase.classification.InterfaceStability;
28 import org.apache.hadoop.hbase.client.Put;
29 import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
30 import org.apache.hadoop.mapred.MapReduceBase;
31 import org.apache.hadoop.mapred.OutputCollector;
32 import org.apache.hadoop.mapred.Reporter;
33
34
35
36
37 @InterfaceAudience.Public
38 @InterfaceStability.Stable
39 public class IdentityTableReduce
40 extends MapReduceBase
41 implements TableReduce<ImmutableBytesWritable, Put> {
42 @SuppressWarnings("unused")
43 private static final Log LOG =
44 LogFactory.getLog(IdentityTableReduce.class.getName());
45
46
47
48
49
50
51
52
53
54 public void reduce(ImmutableBytesWritable key, Iterator<Put> values,
55 OutputCollector<ImmutableBytesWritable, Put> output,
56 Reporter reporter)
57 throws IOException {
58
59 while(values.hasNext()) {
60 output.collect(key, values.next());
61 }
62 }
63 }