From a23816b12a78515354283d639c9fa57537657a37 Mon Sep 17 00:00:00 2001 From: lorenz <stu203404@mail.uni-kiel.de> Date: Fri, 17 Jun 2022 15:00:20 +0200 Subject: [PATCH] HazelcastJet: uc2 fix codestyle --- .../benchmarks/uc2/hazelcastjet/Uc2PipelineFactory.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/Uc2PipelineFactory.java b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/Uc2PipelineFactory.java index cc3ed394f..02e0ceb07 100644 --- a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/Uc2PipelineFactory.java +++ b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/Uc2PipelineFactory.java @@ -20,7 +20,10 @@ import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord; import rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics.StatsAccumulatorSupplier; - +/** + * PipelineFactory for use case 2. + * Allows to build and extend a pipeline. + */ public class Uc2PipelineFactory extends PipelineFactory { private final Duration downsampleInterval; @@ -52,6 +55,7 @@ public class Uc2PipelineFactory extends PipelineFactory { * @return returns a Pipeline used which can be used in a Hazelcast Jet Instance to process data * for UC2. */ + @Override public Pipeline buildPipeline() { // Define the Kafka Source -- GitLab