From 47471e10b4bae5385cb354212832d0b74088b7fc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 15 Apr 2022 23:32:34 +0200
Subject: [PATCH] Use simple pipeline with Samza
---
.../theodolite/benchmarks/uc3/beam/samza/Uc3BeamSamza.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/theodolite-benchmarks/uc3-beam-samza/src/main/java/rocks/theodolite/benchmarks/uc3/beam/samza/Uc3BeamSamza.java b/theodolite-benchmarks/uc3-beam-samza/src/main/java/rocks/theodolite/benchmarks/uc3/beam/samza/Uc3BeamSamza.java
index 247cd99be..33a56c585 100644
--- a/theodolite-benchmarks/uc3-beam-samza/src/main/java/rocks/theodolite/benchmarks/uc3/beam/samza/Uc3BeamSamza.java
+++ b/theodolite-benchmarks/uc3-beam-samza/src/main/java/rocks/theodolite/benchmarks/uc3/beam/samza/Uc3BeamSamza.java
@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.samza;
import org.apache.beam.runners.samza.SamzaRunner;
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
@@ -21,7 +21,7 @@ public final class Uc3BeamSamza {
* Start running this microservice.
*/
public static void main(final String[] args) {
- new BeamService(PipelineFactory.factory(), SamzaRunner.class, args).runStandalone();
+ new BeamService(SimplePipelineFactory.factory(), SamzaRunner.class, args).runStandalone();
}
}
--
GitLab