Skip to content
Snippets Groups Projects
Commit 47471e10 authored by Sören Henning's avatar Sören Henning
Browse files

Use simple pipeline with Samza

parent 6957a8db
No related branches found
No related tags found
No related merge requests found
Pipeline #7937 canceled
...@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.samza; ...@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.samza;
import org.apache.beam.runners.samza.SamzaRunner; import org.apache.beam.runners.samza.SamzaRunner;
import rocks.theodolite.benchmarks.commons.beam.BeamService; 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 * Implementation of the use case Aggregation based on Time Attributes using Apache Beam with the
...@@ -21,7 +21,7 @@ public final class Uc3BeamSamza { ...@@ -21,7 +21,7 @@ public final class Uc3BeamSamza {
* Start running this microservice. * Start running this microservice.
*/ */
public static void main(final String[] args) { public static void main(final String[] args) {
new BeamService(PipelineFactory.factory(), SamzaRunner.class, args).runStandalone(); new BeamService(SimplePipelineFactory.factory(), SamzaRunner.class, args).runStandalone();
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment