From 2860ae73876d97e876b91473d00f0c2f6edc192e Mon Sep 17 00:00:00 2001 From: lorenz <stu203404@mail.uni-kiel.de> Date: Tue, 8 Mar 2022 17:04:09 +0100 Subject: [PATCH] Remove SupressWarring by add correct Type uc2 hzj --- .../uc2/application/Uc2PipelineBuilder.java | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/theodolite/uc2/application/Uc2PipelineBuilder.java b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/theodolite/uc2/application/Uc2PipelineBuilder.java index db7521b2c..12e0b902c 100644 --- a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/theodolite/uc2/application/Uc2PipelineBuilder.java +++ b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/theodolite/uc2/application/Uc2PipelineBuilder.java @@ -108,19 +108,16 @@ public class Uc2PipelineBuilder { * @return An AggregateOperation used by Hazelcast Jet in a streaming stage which aggregates * ActivePowerRecord Objects into Stats Objects. */ - @SuppressWarnings("unchecked") - public AggregateOperation1<Object, StatsAccumulator, Stats> uc2AggregateOperation() { - + public AggregateOperation1<Entry<String, ActivePowerRecord>, + StatsAccumulator, Stats> uc2AggregateOperation() { // Aggregate Operation to Create a Stats Object from Entry<String,ActivePowerRecord> items using // the Statsaccumulator. return AggregateOperation // Creates the accumulator .withCreate(new StatsAccumulatorSupplier()) // Defines the accumulation - .andAccumulate((accumulator, item) -> { - final Entry<String, ActivePowerRecord> castedEntry = - (Entry<String, ActivePowerRecord>) item; - accumulator.add(castedEntry.getValue().getValueInW()); + .<Entry<String, ActivePowerRecord>>andAccumulate((accumulator, item) -> { + accumulator.add(item.getValue().getValueInW()); }) // Defines the combination of spread out instances .andCombine((left, right) -> { @@ -129,9 +126,10 @@ public class Uc2PipelineBuilder { }) // Finishes the aggregation - .andExportFinish((accumulator) -> { - return accumulator.snapshot(); - }); + .andExportFinish( + (accumulator) -> { + return accumulator.snapshot(); + }); } } -- GitLab