beam: Index | Files | Directories

package dataflow

import ""

Package dataflow contains the Dataflow runner for submitting pipelines to Google Cloud Dataflow.


Package Files


func Execute Uses

func Execute(ctx context.Context, p *beam.Pipeline) error

Execute runs the given pipeline on Google Cloud Dataflow. It uses the default application credentials to submit the job.


dataflowlibPackage dataflowlib translates a Beam pipeline model to the Dataflow API job model, for submission to Google Cloud Dataflow.

Package dataflow imports 21 packages (graph) and is imported by 1 packages. Updated 2020-09-03. Refresh now. Tools for package owners.