The proto representation isn't (yet) part of the public API, and is still under active development. However, if you're curious you can see it via calling
pipeline.to_runner_api() in Python or manually invoking classes under https://github.com/apache/beam/tree/master/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction for Java. There's probably some equivalent for Go. (Eventually, the way to get at this would be to implement a Runner whose input would be the proto description itself, but currently both Python and Java represent Pipelines as native objects when invoking runners.) On Tue, Mar 20, 2018 at 2:58 PM Ron Gonzalez <zlgonza...@yahoo.com> wrote: > Hi, > When I build a data flow using the Beam SDK, can someone point me to the > code that represents the underlying representation of the beam model itself? > Is there an API that lets me retrieve the underlying protobuf-based > graph for the data flow? Perhaps some pointers to what code in the runner > retrieves this model in order to execute it in the specific engine? > > Thanks, > Ron >