From 8311a5638782e575d33c30dc1365e9dfbf38bfdb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Thu, 24 Mar 2022 12:24:03 +0100
Subject: [PATCH] Use simple pipeline for Dataflow
---
.../benchmarks/uc3/beam/dataflow/Uc3BeamDataflow.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/theodolite-benchmarks/uc3-beam-dataflow/src/main/java/rocks/theodolite/benchmarks/uc3/beam/dataflow/Uc3BeamDataflow.java b/theodolite-benchmarks/uc3-beam-dataflow/src/main/java/rocks/theodolite/benchmarks/uc3/beam/dataflow/Uc3BeamDataflow.java
index 5c8bc8c42..d708ad4d9 100644
--- a/theodolite-benchmarks/uc3-beam-dataflow/src/main/java/rocks/theodolite/benchmarks/uc3/beam/dataflow/Uc3BeamDataflow.java
+++ b/theodolite-benchmarks/uc3-beam-dataflow/src/main/java/rocks/theodolite/benchmarks/uc3/beam/dataflow/Uc3BeamDataflow.java
@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.dataflow;
import org.apache.beam.runners.dataflow.DataflowRunner;
import rocks.theodolite.benchmarks.commons.beam.BeamService;
-import rocks.theodolite.benchmarks.uc3.beam.PipelineFactory;
+import rocks.theodolite.benchmarks.uc3.beam.SimplePipelineFactory;
/**
* Implementation of the use case Aggregation based on Time Attributes using Apache Beam with the
@@ -16,7 +16,7 @@ public final class Uc3BeamDataflow {
* Start running this microservice.
*/
public static void main(final String[] args) {
- new BeamService(PipelineFactory.factory(), DataflowRunner.class, args).runStandalone();
+ new BeamService(SimplePipelineFactory.factory(), DataflowRunner.class, args).runStandalone();
}
}
--
GitLab