package synthetic

import "github.com/apache/beam/sdks/go/test/integration/synthetic"

Package synthetic contains pipelines for testing synthetic steps and sources.

Index ¶

• func SimplePipeline() *beam.Pipeline
• func SplittablePipeline() *beam.Pipeline

Package Files ¶

synthetic.go

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.