Documentation

Overview

    Package spark contains the Spark 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 runs the given pipeline on Spark. Convenience wrapper over the universal runner.

      Types

      This section is empty.

      Source Files