diff options
author | Stanislav Marszalek <s.marszalek2@partner.samsung.com> | 2021-09-15 18:52:34 +0200 |
---|---|---|
committer | Stanislav Marszalek <s.marszalek2@partner.samsung.com> | 2021-09-15 18:52:34 +0200 |
commit | 3ac3f212d7127e887625a344c3e4846269a01df0 (patch) | |
tree | 989bbfd3c38b8738b62431adf7a5a0f8a790530a /datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java | |
parent | bada18be8dcc91fca5e31f9c0eea60f86f6e7b61 (diff) |
O1 PM Bulk support in DataCollector RAPP - removing trafficModelistanbul
Issue-ID: INT-1947
Signed-off-by: Stanislav Marszalek <s.marszalek2@partner.samsung.com>
Change-Id: I02d3684c98d563d7f386de2fdf032e984ac74b3f
Diffstat (limited to 'datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java')
-rw-r--r-- | datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java b/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java index a3825f6..1cdacd8 100644 --- a/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java +++ b/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java @@ -95,8 +95,8 @@ public class VesRetrievalService implements DmaapRestReader { } private void saveAllEvents(List<Event> events) { - persister.persistAll(events); saveUesOfVes(events); + persister.persistAll(removeTrafficModelFromEvents(events)); } private void saveUesOfVes(List<Event> events) { @@ -113,6 +113,13 @@ public class VesRetrievalService implements DmaapRestReader { .collect(Collectors.toSet())).orElse(Collections.emptySet()); } + private List<Event> removeTrafficModelFromEvents(List<Event> events) { + return events.stream().map(event -> { + event.getMeasurementFields().getAdditionalMeasurements() + .removeIf(additionalMeasurements -> UE_FIELD_NAME.equalsIgnoreCase(additionalMeasurements.getName())); + return event; + }).collect(Collectors.toList()); + } } |