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

package session

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

Index

Package Files

session.go

func Execute Uses

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

Execute launches the supplied pipeline using a session file as the source of inputs.

Package session imports 21 packages (graph). Updated 2019-08-04. Refresh now. Tools for package owners.