runners

package

v2.39.0-RC1 Latest Latest Go to latest Published: May 13, 2022 License: Apache-2.0, BSD-3-Clause, MIT Imports: 1 Imported by: 0

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

github.com/apache/beam

Documentation ¶

Overview ¶

Package runners defines the common "--runner" flag. We have a single definition for it to avoid re-definition errors, between it and test packages or other integration harnesses.

Index ¶

Variables

Constants ¶

This section is empty.

Variables ¶

View Source

var Runner = flag.String("runner", "", "Pipeline runner.")

Runner is a flag to specify which Beam runner should be used to execute the pipeline.

Functions ¶

This section is empty.

Types ¶

This section is empty.

Source Files ¶

View all Source files

flag.go

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.
samza Package samza contains the Samza runner.	Package samza contains the Samza 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