Revision 47714
Added by Alessia Bardi over 7 years ago
modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/claims/ApplyClaimRelsJobNode.java | ||
---|---|---|
72 | 72 |
totalClaims++; |
73 | 73 |
String sourceId = fullId(getOpenAIREType(claim.getSourceType()), claim.getSource()); |
74 | 74 |
String targetId = fullId(getOpenAIREType(claim.getTargetType()), claim.getTarget()); |
75 |
String value = getValue(sourceId, targetId, claim.getSemantics(), timestamp);
|
|
75 |
String value = getValue(sourceId, claim.getSemantics(), targetId, timestamp);
|
|
76 | 76 |
/* |
77 | 77 |
public void addHBaseColumn(final String clusterName, |
78 | 78 |
final String tableName, |
... | ... | |
85 | 85 |
totalWrites++; |
86 | 86 |
|
87 | 87 |
String inverseSemantics = OntologyLoader.fetchInverse(claim.getSemantics()); |
88 |
String inverseValue = getValue(targetId, sourceId, inverseSemantics, timestamp);
|
|
88 |
String inverseValue = getValue(targetId, inverseSemantics, sourceId, timestamp);
|
|
89 | 89 |
hadoopService.addHBaseColumn(clusterName, tableName, targetId, inverseSemantics, sourceId, inverseValue); |
90 | 90 |
totalWrites++; |
91 | 91 |
|
Also available in: Unified diff
Fixed order of arguments