beam: github.com/apache/beam/sdks/go/pkg/beam/runners/vet/testpipeline Index | Files

package testpipeline

import "github.com/apache/beam/sdks/go/pkg/beam/runners/vet/testpipeline"

Package testpipeline exports small test pipelines for testing the vet runner. Shims must be generated for this package in order for tests to run correctly. These shims should be regenerated if changes are made to this package or to the shim generator.

Index

Package Files

functions.go testpipeline.go testpipeline.shims.go

func FunctionReg Uses

func FunctionReg(s beam.Scope)

FunctionReg constructs a sub optimal pipeline that needs function registration.

func KvEmitFn Uses

func KvEmitFn(k string, v int, emit func(string, int))

KvEmitFn is a do nothing example function with a k and v that uses an emit instead of a return.

func KvFn Uses

func KvFn(k string, v int) (string, int)

KvFn is a do nothing example function with a k and v.

func Performant Uses

func Performant(s beam.Scope)

Performant constructs a performant pipeline.

func ShimNeeded Uses

func ShimNeeded(s beam.Scope)

ShimNeeded constructs a sub optimal pipeline that needs a function shim registration.

func TypeReg Uses

func TypeReg(s beam.Scope)

TypeReg constructs a sub optimal pipeline that needs type registration.

func VFloat64Fn Uses

func VFloat64Fn(v float64) (string, int)

VFloat64Fn is an unregistered function without type shims.

func VFn Uses

func VFn(v int) (string, int)

VFn is a do nothing example function with a k and v.

type SCombine Uses

type SCombine struct{}

SCombine is a Do Nothing structural doFn to ensure that generating things for combinefn structs works.

func (*SCombine) MergeAccumulators Uses

func (s *SCombine) MergeAccumulators(a, b int) int

MergeAccumulators lifecycle method.

Package testpipeline imports 7 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.