diff --git a/theodolite-benchmarks/uc3-beam/src/main/java/application/MapTimeFormat.java b/theodolite-benchmarks/uc3-beam/src/main/java/application/MapTimeFormat.java index 909972c2d67cb313f5d92c5787024e867fd76840..bdfb09551fe66d18092495248e3745bd28c084d3 100644 --- a/theodolite-benchmarks/uc3-beam/src/main/java/application/MapTimeFormat.java +++ b/theodolite-benchmarks/uc3-beam/src/main/java/application/MapTimeFormat.java @@ -17,7 +17,7 @@ public class MapTimeFormat extends SimpleFunction<KV<String, ActivePowerRecord>, private final ZoneId zone = ZoneId.of("Europe/Paris"); @Override - public KV<application.HourOfDayKey, ActivePowerRecord> apply( + public KV<HourOfDayKey, ActivePowerRecord> apply( final KV<String, ActivePowerRecord> kv) { final Instant instant = Instant.ofEpochMilli(kv.getValue().getTimestamp()); final LocalDateTime dateTime = LocalDateTime.ofInstant(instant, this.zone);