Add drain() to DataflowPipelineJob

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).