Project

General

Profile

« Previous | Next » 

Revision 57443

Added by Claudio Atzori over 4 years ago

put operations WAS SYNC

View differences:

DedupDeleteRelMapper.java
8 8 
import eu.dnetlib.data.proto.TypeProtos.Type;
9 9 
import eu.dnetlib.pace.config.DedupConfig;
10 10 
import org.apache.hadoop.hbase.client.Delete;
11 
import org.apache.hadoop.hbase.client.Durability;
11 12 
import org.apache.hadoop.hbase.client.Result;
12 13 
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
13 14 
import org.apache.hadoop.hbase.mapreduce.TableMapper;
......
47 48 

  		




  48
  49
  
    
			final byte[] row = rowkey.copyBytes();


  		




  49
  50
  
    
			final Delete delete = new Delete(row);


  		




  50
  
  
    
			delete.setWriteToWAL(JobParams.WRITE_TO_WAL);


  		




  
  51
  
    
			delete.setDurability(Durability.USE_DEFAULT);


  		




  51
  52
  
    

  		




  52
  53
  
    
			delete.deleteFamily(cf);


  		




  53
  54
  
    

  		












Also available in:  Unified diff