beam: Index | Files

package synthetic

import ""

Package synthetic contains pipelines for testing synthetic steps and sources.


Package Files


func SimplePipeline Uses

func SimplePipeline() *beam.Pipeline

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

func SplittablePipeline Uses

func SplittablePipeline() *beam.Pipeline

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

Package synthetic imports 3 packages (graph) and is imported by 1 packages. Updated 2021-01-28. Refresh now. Tools for package owners.