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 247cd99becff8a200185c8fa40efb49bf31a6806..33a56c585d986b855ecac37701f89f0ada9a5030 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();
   }
 
 }