Project

General

Profile

« Previous | Next » 

Revision 52950

Added by Miriam Baglioni over 5 years ago

added counter for debug

View differences:

modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/bulktag/BulkTaggingMapper.java
59 59 
			context.getCounter("In mapper", " bulktagged ").increment(tagged);
60 60 

  		




  61
  61
  
    

  		




  62
  
  
    

  		




  63
  62
  
    
			final Put put = new Put(key.copyBytes()).add(Bytes.toBytes("result"), Bytes.toBytes("body"), oaf.toByteArray());


  		




  64
  63
  
    

  		




  65
  64
  
    
			context.write(key, put);


  		












  

    
      modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/bulktag/ResultTagger.java
    
  





  23
  23
  
    

  		




  24
  24
  
    
    public OafProtos.Oaf enrichContext(final OafProtos.Oaf oaf, final CommunityConfiguration conf, final Mapper.Context context) {


  		




  25
  25
  
    

  		




  
  26
  
    
        context.getCounter(COUNTER_GROUP, "to enrich").increment(1);


  		




  26
  27
  
    
        final OafProtos.Oaf.Builder builder = OafProtos.Oaf.newBuilder(oaf);


  		




  27
  28
  
    

  		




  28
  29
  
    

  		




  ......




  30
  31
  
    
            context.getCounter(COUNTER_GROUP, "deleted by inference").increment(1);


  		




  31
  32
  
    
            return null;


  		




  32
  33
  
    
        }


  		




  
  34
  
    
        context.getCounter(COUNTER_GROUP, "not deleted by inference").increment(1);


  		




  33
  35
  
    

  		




  34
  
  
    

  		




  35
  36
  
    
        final List<ResultProtos.Result.Context> contextList = oaf.getEntity().getResult().getMetadata().getContextList();


  		




  36
  37
  
    

  		




  37
  38
  
    
        //communities contains all the communities to be added as context for the result


  		












Also available in:  Unified diff