package synthetic

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

Package synthetic contains pipelines for testing synthetic steps and sources.

Index

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.

Source Files

synthetic.go

Version
v2.65.0 (latest)
Published
May 6, 2025
Platform
linux/amd64
Imports
3 packages
Last checked
1 day ago

Tools for package owners.