Hi Beam Dev, Fn API overview [1] suggests using a docker container to encapsulate the language-specific SDK harness. I'd like to propose to add a pipeline option to Beam SDKs, to pass the container image to a runner.
For example, in Python SDK this option can be called sdk_harness_container_image , and in Java SDK it could be sdkHarnessContainerImage. The presence of this option should be treated by Beam Runners as a signal that FnAPI should be used to process the pipeline. Any objections? Also, since this is my first email to the list -- I am Valentyn and I am very excited to join Beam community. I'll be working alongside Lukasz, Vikas, Ahmet and others on various aspects of Beam portability and FnAPI. Thanks you. [1] https://s.apache.org/beam-fn-api
