Back to / sdks / go / pkg / beam / runners / flink

package flink

Latest Go to latest
Published: Jun 3, 2020 | License: Apache-2.0 | Module:


Package flink contains the Flink runner.


func Execute

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

Execute runs the given pipeline on Flink. Convenience wrapper over the universal runner.

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier