Skip to content
Snippets Groups Projects
Commit 52ba8daf authored by Sören Henning's avatar Sören Henning
Browse files

Fix code style issues

parent d9e49b8d
Branches
Tags
1 merge request!266Move Titan classes to Theodolite
Pipeline #8571 passed
package rocks.theodolite.benchmarks.uc4.hazelcastjet; package rocks.theodolite.benchmarks.uc4.hazelcastjet; // NOPMD Excessive imports
import com.hazelcast.function.BiFunctionEx; import com.hazelcast.function.BiFunctionEx;
import com.hazelcast.jet.Traverser; import com.hazelcast.jet.Traverser;
...@@ -38,7 +38,6 @@ import rocks.theodolite.benchmarks.uc4.hazelcastjet.uc4specifics.ValueGroup; ...@@ -38,7 +38,6 @@ import rocks.theodolite.benchmarks.uc4.hazelcastjet.uc4specifics.ValueGroup;
* Builder to build a HazelcastJet Pipeline for UC4 which can be used for stream processing using * Builder to build a HazelcastJet Pipeline for UC4 which can be used for stream processing using
* Hazelcast Jet. * Hazelcast Jet.
*/ */
@SuppressWarnings("PMD.ExcessiveImports")
public class Uc4PipelineBuilder { public class Uc4PipelineBuilder {
private static final Logger LOGGER = LoggerFactory.getLogger(Uc4PipelineBuilder.class); private static final Logger LOGGER = LoggerFactory.getLogger(Uc4PipelineBuilder.class);
...@@ -239,7 +238,7 @@ public class Uc4PipelineBuilder { ...@@ -239,7 +238,7 @@ public class Uc4PipelineBuilder {
dupliAsFlatmappedStage dupliAsFlatmappedStage
.window(WindowDefinition.tumbling(windowSize)); .window(WindowDefinition.tumbling(windowSize));
final AggregateOperation1<Entry<SensorGroupKey, ActivePowerRecord>, AggregatedActivePowerRecordAccumulator, AggregatedActivePowerRecord> aggrOp = final AggregateOperation1<Entry<SensorGroupKey, ActivePowerRecord>, AggregatedActivePowerRecordAccumulator, AggregatedActivePowerRecord> aggrOp = // NOCS
AggregateOperation AggregateOperation
.withCreate(AggregatedActivePowerRecordAccumulator::new) .withCreate(AggregatedActivePowerRecordAccumulator::new)
.<Entry<SensorGroupKey, ActivePowerRecord>>andAccumulate((acc, rec) -> { .<Entry<SensorGroupKey, ActivePowerRecord>>andAccumulate((acc, rec) -> {
......
...@@ -15,15 +15,15 @@ import org.apache.kafka.streams.kstream.Materialized; ...@@ -15,15 +15,15 @@ import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.kstream.Produced; import org.apache.kafka.streams.kstream.Produced;
import org.apache.kafka.streams.kstream.Suppressed; import org.apache.kafka.streams.kstream.Suppressed;
import org.apache.kafka.streams.kstream.Suppressed.BufferConfig; import org.apache.kafka.streams.kstream.Suppressed.BufferConfig;
import org.apache.kafka.streams.kstream.TimeWindows;
import org.apache.kafka.streams.kstream.Windowed;
import org.apache.kafka.streams.kstream.WindowedSerdes;
import rocks.theodolite.benchmarks.commons.configuration.events.Event; import rocks.theodolite.benchmarks.commons.configuration.events.Event;
import rocks.theodolite.benchmarks.commons.configuration.events.EventSerde; import rocks.theodolite.benchmarks.commons.configuration.events.EventSerde;
import rocks.theodolite.benchmarks.commons.kafka.avro.SchemaRegistryAvroSerdeFactory; import rocks.theodolite.benchmarks.commons.kafka.avro.SchemaRegistryAvroSerdeFactory;
import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord; import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord;
import rocks.theodolite.benchmarks.commons.model.records.AggregatedActivePowerRecord; import rocks.theodolite.benchmarks.commons.model.records.AggregatedActivePowerRecord;
import rocks.theodolite.benchmarks.commons.model.sensorregistry.SensorRegistry; import rocks.theodolite.benchmarks.commons.model.sensorregistry.SensorRegistry;
import org.apache.kafka.streams.kstream.TimeWindows;
import org.apache.kafka.streams.kstream.Windowed;
import org.apache.kafka.streams.kstream.WindowedSerdes;
/** /**
* Builds Kafka Stream Topology for the History microservice. * Builds Kafka Stream Topology for the History microservice.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment