regression

Documentation

Overview

Package regression contains pipeline regression tests.

Index

• func DirectParDo() *beam.Pipeline
• func DirectParDoAfterGBK() *beam.Pipeline
• func EmitParDo() *beam.Pipeline
• func EmitParDoAfterGBK() *beam.Pipeline
• func MixedOutputParDo() *beam.Pipeline
• func MultiEmitParDo() *beam.Pipeline

Functions

func DirectParDo

func DirectParDo() *beam.Pipeline

DirectParDo tests direct form output DoFns.

func DirectParDoAfterGBK

func DirectParDoAfterGBK() *beam.Pipeline

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

func EmitParDo

func EmitParDo() *beam.Pipeline

EmitParDo tests emit form output DoFns.

func EmitParDoAfterGBK

func EmitParDoAfterGBK() *beam.Pipeline

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

func MixedOutputParDo

func MixedOutputParDo() *beam.Pipeline

MixedOutputParDo tests mixed direct + emit form output DoFns.

func MultiEmitParDo

func MultiEmitParDo() *beam.Pipeline

MultiEmitParDo tests double emit form output DoFns.