package
2.59.0
Repository: https://github.com/leocbs/beam.git
Documentation: pkg.go.dev

# Packages

No description provided by the author

# Functions

DirectParDo tests direct form output DoFns.
DirectParDoAfterGBK generates a pipeline with a direct-form ParDo after a GBK.
EmitParDo tests emit form output DoFns.
EmitParDoAfterGBK generates a pipeline with a emit-form ParDo after a GBK.
LPErrorPipeline constructs a pipeline that has a GBK followed by a CoGBK using the same input, with schema encoded structs as elements.
LPErrorReshufflePipeline checks a Row type with reshuffle transforms.
MixedOutputParDo tests mixed direct + emit form output DoFns.
MultiEmitParDo tests double emit form output DoFns.

# Constants

FruitCounterName is the name of the fruit counter metric.
MetricNamespace is the namespace for regression test metrics.