Visualize #
Visualize the Beam pipelines:
# assuming there's already a pipeline definition
import apache_beam.runners.interactive.interactive_beam as ib
ib.show_graph(pipeline)
Visualize
Visualize the Beam pipelines:
# assuming there's already a pipeline definition
import apache_beam.runners.interactive.interactive_beam as ib
ib.show_graph(pipeline)