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

package regression

import "github.com/apache/beam/sdks/go/test/regression"

Package regression contains pipeline regression tests.

Index

Package Files

pardo.go

func DirectParDo Uses

func DirectParDo() *beam.Pipeline

DirectParDo tests direct form output DoFns.

func DirectParDoAfterGBK Uses

func DirectParDoAfterGBK() *beam.Pipeline

DirectParDoAfterGBK generates a pipeline with a direct-form ParDo after a GBK. See: BEAM-3978 and BEAM-4175.

func EmitParDo Uses

func EmitParDo() *beam.Pipeline

EmitParDo tests emit form output DoFns.

func EmitParDoAfterGBK Uses

func EmitParDoAfterGBK() *beam.Pipeline

EmitParDoAfterGBK generates a pipeline with a emit-form ParDo after a GBK. See: BEAM-3978 and BEAM-4175.

func MixedOutputParDo Uses

func MixedOutputParDo() *beam.Pipeline

MixedOutputParDo tests mixed direct + emit form output DoFns.

func MultiEmitParDo Uses

func MultiEmitParDo() *beam.Pipeline

MultiEmitParDo tests double emit form output DoFns.

Package regression imports 3 packages (graph). Updated 2020-10-28. Refresh now. Tools for package owners.