Oh good. That's exactly what I needed. Thanks! Sent from my iPhone
> On Apr 21, 2017, at 17:45, Lukasz Cwik <[email protected]> wrote: > > It was removed because many of the fields stored in PipelineOptions were not > really cloneable but used as a way to pass around items such as an > ExecutorService or Credentials for dependency injection reasons. > > With the above caveat that your not getting a true clone, feel free to copy > the code shown in either of: > https://github.com/apache/beam/blob/master/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/SerializedPipelineOptions.java > https://github.com/apache/beam/blob/master/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/SerializablePipelineOptions.java > > >> On Fri, Apr 21, 2017 at 5:40 PM, Ankur Chauhan <[email protected]> wrote: >> Hi >> >> I am attempting to build a sort of a supervisor process for dataflow >> pipelines that starts up dataflow jobs based on some inputs combined with >> some common presets. I used to use the cloneAs method on the pipelineoptions >> class but noticed that if has been removed and wanted to ask if there was a >> way to sort of "serialize", "deserialize" and clone existing option >> instances for easy reusability. >> >> -- AC >> >> Sent from my iPhone >
