Revision 57443
Added by Claudio Atzori over 4 years ago
FindDedupCandidatePersonsReducer.java | ||
---|---|---|
8 | 8 |
import java.util.Set; |
9 | 9 |
|
10 | 10 |
import eu.dnetlib.data.mapreduce.JobParams; |
11 |
import org.apache.hadoop.hbase.client.Durability; |
|
11 | 12 |
import org.apache.hadoop.hbase.client.Put; |
12 | 13 |
import org.apache.hadoop.hbase.io.ImmutableBytesWritable; |
13 | 14 |
import org.apache.hadoop.hbase.mapreduce.TableReducer; |
... | ... | |
105 | 106 |
for (final String s : resultIds.get(personId)) { |
106 | 107 |
final byte[] id = Bytes.toBytes(s); |
107 | 108 |
final Put put = new Put(id).add(cf, col, val); |
108 |
put.setWriteToWAL(JobParams.WRITE_TO_WAL);
|
|
109 |
put.setDurability(Durability.USE_DEFAULT);
|
|
109 | 110 |
context.write(new ImmutableBytesWritable(id), put); |
110 | 111 |
} |
111 | 112 |
context.getCounter(getClass().getSimpleName(), "N. Put. (results)").increment(resultIds.get(personId).size()); |
Also available in: Unified diff
put operations WAS SYNC