Skip to content
Snippets Groups Projects
Commit a23816b1 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

HazelcastJet: uc2 fix codestyle

parent 15b82e83
No related branches found
No related tags found
1 merge request!275Refactor hazelcast jet benchmarks:
...@@ -20,7 +20,10 @@ import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord; ...@@ -20,7 +20,10 @@ import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord;
import rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics.StatsAccumulatorSupplier; 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 { public class Uc2PipelineFactory extends PipelineFactory {
private final Duration downsampleInterval; private final Duration downsampleInterval;
...@@ -52,6 +55,7 @@ public class Uc2PipelineFactory extends PipelineFactory { ...@@ -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 * @return returns a Pipeline used which can be used in a Hazelcast Jet Instance to process data
* for UC2. * for UC2.
*/ */
@Override
public Pipeline buildPipeline() { public Pipeline buildPipeline() {
// Define the Kafka Source // Define the Kafka Source
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment