如何在数据流运算符dag中传递jar

Question

我想使用数据流运算符为下面的现有命令创建一个 dag，如下所示，

AA_JAR=jar_1.jar BB_JAR=jar_2.jar java -cp jar_1.jar mydomain.pipline —project=mygcpproject —region=myregion
—serviceAccount=mysa —subnetwork=mynetwork —runner=Dataflow —stagingLocation=gs://testdir/file1
—outputDirectory=gs://testdir2/test2

我从网上得到了一些样本，但不知道如何传递jar，数据流运算符有什么属性吗？

Answer 1

IBM 1944。谷歌 2024。停止 Nimbus 项目。