Project

General

Profile

1
package eu.dnetlib.data.mapreduce.hbase.dedup.preprocess;
2

    
3
import java.io.IOException;
4

    
5
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
6
import org.apache.hadoop.io.Text;
7
import org.apache.hadoop.mapreduce.Reducer;
8

    
9
public class ExportFullnameReducer extends Reducer<ImmutableBytesWritable, Text, Text, Text> {
10

    
11
	private Text outValue;
12

    
13
	@Override
14
	protected void setup(final Context context) throws IOException, InterruptedException {
15

    
16
		outValue = new Text("");
17
	}
18

    
19
	@Override
20
	protected void reduce(final ImmutableBytesWritable key, final Iterable<Text> values, final Context context) throws IOException, InterruptedException {
21

    
22
		for (final Text fullname : values) {
23
			context.write(fullname, outValue);
24

    
25
		}
26
	}
27

    
28
}
(2-2/2)