beam: github.com/apache/beam/sdks/go/test/integration/synthetic Index | Files

package synthetic

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

Package synthetic contains pipelines for testing synthetic steps and sources.

Index

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.

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