universal

package
Version: v2.25.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package universal contains a general-purpose runner that can submit jobs to any portable Beam runner.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Execute

func Execute(ctx context.Context, p *beam.Pipeline) error

Execute executes the pipeline on a universal beam runner.

Types

This section is empty.

Source Files

Directories

Path Synopsis
Package extworker provides an external worker service and related utilities.
Package extworker provides an external worker service and related utilities.
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.

Jump to

Keyboard shortcuts

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