runners/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Path	Synopsis
dataflow Package dataflow contains the Dataflow runner for submitting pipelines to Google Cloud Dataflow.	Package dataflow contains the Dataflow runner for submitting pipelines to Google Cloud Dataflow.
dataflowlib Package dataflowlib translates a Beam pipeline model to the Dataflow API job model, for submission to Google Cloud Dataflow.	Package dataflowlib translates a Beam pipeline model to the Dataflow API job model, for submission to Google Cloud Dataflow.
direct Package direct contains the direct runner for running single-bundle pipelines in the current process.	Package direct contains the direct runner for running single-bundle pipelines in the current process.
dot Package dot is a Beam runner that "runs" a pipeline by producing a DOT graph of the execution plan.	Package dot is a Beam runner that "runs" a pipeline by producing a DOT graph of the execution plan.
flink Package flink contains the Flink runner.	Package flink contains the Flink runner.
session
universal Package universal contains a general-purpose runner that can submit jobs to any portable Beam runner.	Package universal contains a general-purpose runner that can submit jobs to any portable Beam runner.
runnerlib Package runnerlib contains utilities for submitting Go pipelines to a Beam model runner.	Package runnerlib contains utilities for submitting Go pipelines to a Beam model runner.