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 <[email protected]> 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
>
