import "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"
Package dataflow contains the Dataflow runner for submitting pipelines to Google Cloud Dataflow.
Execute runs the given pipeline on Google Cloud Dataflow. It uses the default application credentials to submit the job.
Path | Synopsis |
---|---|
dataflowlib | Package 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 2 packages. Updated 2021-01-25. Refresh now. Tools for package owners.