別のパイプライン内からパイプラインを排水するにはどうすればよいですか？

Question

別のパイプラインからプログラムでパイプラインを排除する必要があります。 DataflowPipelineJobクラスにはdrainメソッドが実装されていません。パイプライン上でdrainをJava APIから呼び出すことは可能ですか？

Answer 1

次のコードと排出を開始することができた：

// spawn child pipe 
    DataflowPipelineRunner runner = DataflowPipelineRunner.fromOptions(options); 
    DataflowPipelineJob job = runner.run(p); 

    // under the some condition later, drain the spawned pipe: 
    Dataflow client = com.google.cloud.dataflow.sdk.util.Transport.newDataflowClient(options).build(); 
    Job content = new Job(); 
    content.setProjectId(options.getProject()); 
    content.setId(job.getJobId()); 
    content.setRequestedState("JOB_STATE_DRAINING"); 
    client.projects().jobs() 
      .update(options.getProject(), job.getJobId(), content) 
      .execute();