beam: github.com/apache/beam/sdks/go/examples/forest Files

Command forest

forest is an example that shows that pipeline construction is normal Go code -- the pipeline "forest" is created recursively and uses a global variable -- and that a pipeline may contain non-connected parts.

The pipeline generated has the shape of a forest where the output of each singleton leaf is flattened together over several rounds. This is most clearly seen via a visual representation of the pipeline, such as the one produced by the 'dot' runner.

Running the pipeline logs "1", "2", "3", etc for each leaf in the forest. Note that different runners may produces different or non-deterministic orders.

Package Files

forest.go

Package main imports 6 packages (graph). Updated 2018-04-24. Refresh now. Tools for package owners. This is an inactive package (no imports and no commits in at least two years).