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

Repository

Directories ¶

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
spark Package spark contains the Spark runner.	Package spark contains the Spark runner.
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.
extworker Package extworker provides an external worker service and related utilities.	Package extworker provides an external worker service and related utilities.
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.
vet Package vet is a Beam runner that "runs" a pipeline by producing generated code to avoid symbol table lookups and reflection in pipeline execution.	Package vet is a Beam runner that "runs" a pipeline by producing generated code to avoid symbol table lookups and reflection in pipeline execution.
testpipeline Package testpipeline exports small test pipelines for testing the vet runner.	Package testpipeline exports small test pipelines for testing the vet runner.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL