Project

General

Profile

« Previous | Next » 

Revision 57443

Added by Claudio Atzori over 4 years ago

put operations WAS SYNC

View differences:

PromoteActionSetFromHDFSMapper.java
4 4 

  		




  5
  5
  
    
import eu.dnetlib.actionmanager.actions.AtomicAction;


  		




  6
  6
  
    
import eu.dnetlib.data.mapreduce.JobParams;


  		




  
  7
  
    
import org.apache.hadoop.hbase.client.Durability;


  		




  7
  8
  
    
import org.apache.hadoop.hbase.client.Put;


  		




  8
  9
  
    
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;


  		




  9
  10
  
    
import org.apache.hadoop.hbase.util.Bytes;


  		




  ......




  31
  32
  
    
		final byte[] keyOutBytes = Bytes.toBytes(aa.getTargetRowKey());


  		




  32
  33
  
    
		keyOut.set(keyOutBytes);


  		




  33
  34
  
    
		final Put put = new Put(keyOutBytes);


  		




  34
  
  
    
		put.setWriteToWAL(JobParams.WRITE_TO_WAL);


  		




  
  35
  
    
		put.setDurability(Durability.USE_DEFAULT);


  		




  35
  36
  
    
		put.add(Bytes.toBytes(aa.getTargetColumnFamily()), Bytes.toBytes(aa.getTargetColumn()), aa.getTargetValue());


  		




  36
  37
  
    

  		




  37
  38
  
    
		context.write(keyOut, put);


  		












Also available in:  Unified diff