我正在编写一个应用程序,该应用程序试图根据参数提供的参数启动批处理数据流管道。为此,我使用PipelineOptionsFactory.create().as(...)at com.google.cloud.dataflow.sdk.util.InstanceBuilder.build(InstanceBuilder.java:163)
at com.google.cloud.dataflow.sdk.runners.PipelineRunner.fromOptionsat com.brightcove.rna.d