Project

General

Profile

« Previous | Next » 

Revision 54716

Added by Miriam Baglioni over 5 years ago

actually incrementing the counters just added

View differences:

modules/dnet-mapreduce-jobs/branches/master/src/main/java/eu/dnetlib/data/mapreduce/hbase/bulktag/ResultTagger.java
62 62 
                .forEach(s -> subjects.addAll(conf.getCommunityForSubjectValue(s)));
63 63 

  		




  64
  64
  
    
        //updating counters for subject matching


  		




  65
  
  
    
        subjects.forEach(c->context.getCounter(COUNTER_GROUP, "Matching subject for community " + c));


  		




  
  65
  
    
        subjects.forEach(c->context.getCounter(COUNTER_GROUP, "Matching subject for community " + c).increment(1));


  		




  66
  66
  
    
        communities.addAll(subjects);


  		




  67
  67
  
    

  		




  68
  68
  
    
        final Set<String> datasources = new HashSet<>();


  		




  ......




  74
  74
  
    
                .collect(Collectors.toCollection(HashSet::new))


  		




  75
  75
  
    
                .forEach(dsId -> datasources.addAll(conf.getCommunityForDatasourceValue(dsId)));


  		




  76
  76
  
    

  		




  77
  
  
    
        datasources.forEach(c->context.getCounter(COUNTER_GROUP,"Matching datasource for community " + c));


  		




  
  77
  
    
        datasources.forEach(c->context.getCounter(COUNTER_GROUP,"Matching datasource for community " + c).increment(1));


  		




  78
  78
  
    
        communities.addAll(datasources);


  		




  79
  79
  
    

  		




  80
  80
  
    
        final Set<String> czenodo = new HashSet<>();


  		




  ......




  82
  82
  
    
        mBuilder.getContextBuilderList().stream().filter(cBuilder -> cBuilder.getId().contains(ZENODO_COMMUNITY_INDICATOR))


  		




  83
  83
  
    
                .collect(Collectors.toList())


  		




  84
  84
  
    
                .forEach(c->czenodo.addAll(conf.getCommunityForZenodoCommunityValue(c.getId().substring(c.getId().lastIndexOf("/")+1).trim())));


  		




  85
  
  
    
        czenodo.forEach(c->context.getCounter(COUNTER_GROUP,"Matching Zenodo community for community " + c));


  		




  
  85
  
    
        czenodo.forEach(c->context.getCounter(COUNTER_GROUP,"Matching Zenodo community for community " + c).increment(1));


  		




  86
  86
  
    

  		




  87
  87
  
    
        communities.addAll(czenodo);


  		




  88
  88
  
    
        List<Context.Builder> clist = mBuilder.getContextBuilderList().stream()


  		












Also available in:  Unified diff