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

HazelcastJet: uc3 fix codestyle

parent a23816b1
No related branches found
No related tags found
1 merge request!275Refactor hazelcast jet benchmarks:
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment