Revision 52944
Added by Miriam Baglioni over 5 years ago
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