如何从另一个管道中排出管道？

【问题标题】：How do I drain a pipeline from within another pipeline?如何从另一个管道中排出管道？
【发布时间】：2017-01-15 13:14:24
【问题描述】：

我需要以编程方式从另一个管道中排出管道。 DataflowPipelineJob 类没有实现 drain 方法。是否可以使用 Java API 在管道上调用drain？

【问题讨论】：

标签： java google-cloud-dataflow

【解决方案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();

【讨论】：