Project

General

Profile

« Previous | Next » 

Revision 57443

put operations WAS SYNC

View differences:

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