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) (beam.PipelineResult, 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 2 packages. Updated 2021-01-25. Refresh now. Tools for package owners.