Revision 44130
Added by Claudio Atzori over 7 years ago
| DedupSimilarityToHdfsActionsMapper.java | ||
|---|---|---|
| 76 | 76 |
final AtomicAction aa = actionFactory.createAtomicAction(rawSet, agent, targetKey, similarityCF, qualifier, null); |
| 77 | 77 |
|
| 78 | 78 |
keyOut.set(aa.getTargetRowKey()+"@"+aa.getTargetColumnFamily()+"@"+aa.getTargetColumn()); |
| 79 |
valueOut.set(aa.toString());
|
|
| 79 |
valueOut.set(aa.toJSON());
|
|
| 80 | 80 |
|
| 81 | 81 |
context.write(keyOut, valueOut); |
| 82 | 82 |
context.getCounter(dedupConf.getWf().getEntityType(), "similarity2actions").increment(1); |
Also available in: Unified diff
align with latest dnet-actionmanager-common