Revision 52944
Added by Miriam Baglioni over 5 years ago
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/bulktag/BulkTaggingMapper.java | ||
|---|---|---|
| 58 | 58 |
.count(); |
| 59 | 59 |
context.getCounter("In mapper", " bulktagged ").increment(tagged);
|
| 60 | 60 |
|
| 61 |
// |
|
| 62 |
// List<ResultProtos.Result.Context> tmp = oaf.getEntity().getResult().getMetadata().getContextList(); |
|
| 63 |
// for(ResultProtos.Result.Context c:tmp){
|
|
| 64 |
// for(FieldTypeProtos.DataInfo d:c.getDataInfoList()){
|
|
| 65 |
// if (d.getInferenceprovenance().equals("bulktagging::community")){
|
|
| 66 |
// context.getCounter("In mapper", " bulktagged ").increment(1);
|
|
| 67 |
// } |
|
| 68 |
// } |
|
| 69 |
// } |
|
| 70 | 61 |
|
| 62 |
|
|
| 71 | 63 |
final Put put = new Put(key.copyBytes()).add(Bytes.toBytes("result"), Bytes.toBytes("body"), oaf.toByteArray());
|
| 72 | 64 |
|
| 73 | 65 |
context.write(key, put); |
Also available in: Unified diff
refactoring