gCubeSystem
/
accounting-aggregator-se-plugin
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added malformed records management 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-aggregator-se-plugin@153109 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Luca Frosini 2017-09-15 09:08:52 +00:00
parent 4466e2bbac
commit 0d7235a52b
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/gcube/accounting/aggregator/aggregation/Aggregator.java
View File

@ -200,8 +200,7 @@ public class Aggregator {
aggregateRecordsBackupFileTmp.renameTo(aggregateRecordsBackupFile);
aggregationStatus.setRecordNumbers(originalRecordsCounter, aggregatedRecords.size());
aggregationStatus.setMalformedRecordNumber(malformedRecordNumber);
aggregationStatus.setRecordNumbers(originalRecordsCounter, aggregatedRecords.size(), malformedRecordNumber);
aggregationStatus.setState(AggregationState.AGGREGATED, startTime, true);
}

7
src/main/java/org/gcube/accounting/aggregator/status/AggregationStatus.java
View File

@ -108,11 +108,12 @@ public class AggregationStatus {
}
}
public void setRecordNumbers(int originalRecordsNumber, int aggregatedRecordsNumber) {
public void setRecordNumbers(int originalRecordsNumber, int aggregatedRecordsNumber, int malformedRecordNumber) {
this.recoveredRecordNumber = originalRecordsNumber - aggregatedRecordsNumber;
this.percentage = originalRecordsNumber!=0 ? (100 * recoveredRecordNumber) / originalRecordsNumber : 0;
logger.info("Original records are {}. Aggregated records are {}. Difference {}. We recover {}% of Documents",
originalRecordsNumber, aggregatedRecordsNumber, recoveredRecordNumber, percentage);
logger.info("Original records are {} ({} were malformed). Aggregated records are {}. Difference {}. We recover {}% of Documents",
originalRecordsNumber, malformedRecordNumber, aggregatedRecordsNumber, recoveredRecordNumber, percentage);
this.malformedRecordNumber = malformedRecordNumber;
this.originalRecordsNumber = originalRecordsNumber;
this.aggregatedRecordsNumber = aggregatedRecordsNumber;
}