From 4b981687b6c52fea4b5ee8d75501396926e02149 Mon Sep 17 00:00:00 2001 From: lorenz <stu203404@mail.uni-kiel.de> Date: Fri, 17 Jun 2022 15:02:07 +0200 Subject: [PATCH] HazelcastJet: uc3 fix codestyle --- .../benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java index 0414fee3f..474a9e857 100644 --- a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java +++ b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineFactory.java @@ -23,6 +23,10 @@ import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HoursOfDayKeyFa import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.StatsKeyFactory; +/** + * PipelineFactory for use case 3. + * Allows to build and extend pipelines. + */ public class Uc3PipelineFactory extends PipelineFactory { private final Duration hoppingSize; @@ -60,6 +64,7 @@ public class Uc3PipelineFactory extends PipelineFactory { * @return a pipeline used which can be used in a Hazelcast Jet Instance to process data * for UC3. */ + @Override public Pipeline buildPipeline() { // Define the source -- GitLab