Documentation

Overview

    Package synthetic contains pipelines for testing synthetic steps and sources.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func SimplePipeline

    func SimplePipeline() *beam.Pipeline

      SimplePipeline creates a very simple synthetic pipeline to test that basic synthetic pipelines work.

      func SplittablePipeline

      func SplittablePipeline() *beam.Pipeline

        SplittablePipeline creates a simple synthetic pipeline that exercises splitting-related behavior.

        Types

        This section is empty.

        Source Files