Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Execute 

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

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

Types

This section is empty.

Source Files

View all