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

Merge branch 'beam-pubsub' into firestore-test

parents f2876cea 7c00045f
No related branches found
No related tags found
No related merge requests found
Pipeline #7212 passed
Stage: build
Stage: test
Stage: check
Stage: deploy
Stage: smoketest
Show whitespace changes
Inline Side-by-side
theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/PipelineFactory.java
+ 1
− 1
View file @ d63b0873
...@@ -61,7 +61,7 @@ public class PipelineFactory extends AbstractPipelineFactory { ...@@ -61,7 +61,7 @@ public class PipelineFactory extends AbstractPipelineFactory {
if (subscription == null) { if (subscription == null) {
activePowerRecords = pipeline.apply(PubSubSource.forTopic(topic, project)); activePowerRecords = pipeline.apply(PubSubSource.forTopic(topic, project));
} else { } else {
activePowerRecords = pipeline.apply(PubSubSource.forSubscription(topic, subscription)); activePowerRecords = pipeline.apply(PubSubSource.forSubscription(project, subscription));
} }
} else { } else {
final KafkaActivePowerTimestampReader kafka = super.buildKafkaReader(); final KafkaActivePowerTimestampReader kafka = super.buildKafkaReader();
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment