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 cc3ed394feffd4492b125a4bb085e21109ce61dc..02e0ceb07e95bddb6c6fc1540f75a19642ee58a2 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