Sam Whittle created BEAM-7913:
---------------------------------
Summary: Add drain() to DataflowPipelineJob
Key: BEAM-7913
URL: https://issues.apache.org/jira/browse/BEAM-7913
Project: Beam
Issue Type: Improvement
Components: runner-dataflow
Reporter: Sam Whittle
Assignee: Sam Whittle
Dataflow supports draining jobs but there is no easy programatic way to do it.
I propose adding a drain() method to DataflowPipelineJob similar to the
existing cancel() method (inherited from PipelineResult).
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
