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.

Reply via email to