Revision 48139
Added by Alessia Bardi almost 7 years ago
| ApplyClaimUpdatesJobNode.java | ||
|---|---|---|
| 35 | 35 |
HadoopService hadoopService = getServiceLocator().getService(HadoopService.class); |
| 36 | 36 |
|
| 37 | 37 |
for (Claim claim : claimUpdates) {
|
| 38 |
try{
|
|
| 39 |
log.debug(claim); |
|
| 40 |
String contextId = claim.getSource(); |
|
| 41 |
String rowKey = getFullId(getOpenAIREType(claim.getTargetType()), claim.getTarget()); |
|
| 38 |
try {
|
|
| 39 |
log.debug(claim);
|
|
| 40 |
String contextId = claim.getSource();
|
|
| 41 |
String rowKey = getFullId(getOpenAIREType(claim.getTargetType()), claim.getTarget());
|
|
| 42 | 42 |
|
| 43 |
String value = getValue(rowKey, contextId , timestamp);
|
|
| 44 |
hadoopService.addHBaseColumn(getClusterName(), getTableName(), rowKey, "result", "update_" + System.nanoTime(), value); |
|
| 45 |
incrementProcessed(); |
|
| 43 |
String value = getValue(rowKey, contextId, timestamp);
|
|
| 44 |
hadoopService.addHBaseColumn(getClusterName(), getTableName(), rowKey, "result", "update_" + System.nanoTime(), value);
|
|
| 45 |
incrementProcessed();
|
|
| 46 | 46 |
} catch (IllegalArgumentException e) {
|
| 47 | 47 |
log.error("Discarding claim " + claim + ". Cause: " + e.getMessage());
|
| 48 | 48 |
discardedClaims++; |
Also available in: Unified diff
integrated (hopefully) all required changes from dnet40