Documentation ¶ Index ¶ func Execute(ctx context.Context, p *beam.Pipeline) error 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 Source files session.go Click to show internal directories. Click to hide internal directories.