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

Hazelcast: uc1 fix codestyle

parent 9b5ae78d
No related branches found
No related tags found
1 merge request!275Refactor hazelcast jet benchmarks:
......@@ -8,12 +8,15 @@ import com.hazelcast.jet.pipeline.StreamSource;
import com.hazelcast.jet.pipeline.StreamStage;
import java.util.Map;
import java.util.Properties;
import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord;
import rocks.theodolite.benchmarks.commons.hazelcastjet.PipelineFactory;
import rocks.theodolite.benchmarks.commons.model.records.ActivePowerRecord;
import rocks.theodolite.benchmarks.uc1.commons.DatabaseAdapter;
import rocks.theodolite.benchmarks.uc1.commons.DatabaseWriter;
import rocks.theodolite.benchmarks.uc1.commons.logger.LogWriterFactory;
/**
* PipelineFactory for use case 1.
*/
public class Uc1PipelineFactory extends PipelineFactory {
private final DatabaseAdapter<String> databaseAdapter = LogWriterFactory.forJson();
......@@ -33,6 +36,7 @@ public class Uc1PipelineFactory extends PipelineFactory {
*
* @return A Hazelcast Jet pipeline which processes data for Uc1.
*/
@Override
public Pipeline buildPipeline() {
// Define the Kafka 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