Accessing the runner in your transform's expand() method can't work, in general: Your transform is / will be expanded to build a runner-independent graph before a runner is selected.
I'm curious - what is it that you are using it for? On Wed, Apr 5, 2017 at 7:22 AM, Antony Mayi <[email protected]> wrote: > reading through BEAM-818 and https://docs.google.com/ > document/d/1Wr05cYdqnCfrLLqSk--XmGMGgDwwNwWZaFbxLKvPqEQ/edit# > > if I am currently doing something like this: > > public class MyTransform extends PTransform<String, String> { > @Override public String expand(PCollection<String> input) { > Class<? extends PipelineRunner<?>> runner = > input.getPipeline().getOptions().getRunner(); > > > is the expected way to obtain the runner class after the > Pipeline.getOptions() is deprecated to pass it via MyTransform constructor > and keeping a reference to it? > > thanks Antony. >
