beam: github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow Index | Files | Directories

package dataflow

import "github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow"

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

Index

Package Files

dataflow.go

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.

Directories

PathSynopsis
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 2019-12-13. Refresh now. Tools for package owners.