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

Use simple pipeline for Dataflow

parent 29dbaa24
No related branches found
No related tags found
No related merge requests found
...@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.dataflow; ...@@ -2,7 +2,7 @@ package rocks.theodolite.benchmarks.uc3.beam.dataflow;
import org.apache.beam.runners.dataflow.DataflowRunner; import org.apache.beam.runners.dataflow.DataflowRunner;
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
...@@ -16,7 +16,7 @@ public final class Uc3BeamDataflow { ...@@ -16,7 +16,7 @@ public final class Uc3BeamDataflow {
* 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(), DataflowRunner.class, args).runStandalone(); new BeamService(SimplePipelineFactory.factory(), DataflowRunner.class, args).runStandalone();
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment