package debug

import "github.com/apache/beam/sdks/v2/go/pkg/beam/x/debug"

Package debug contains pipeline components that may help in debugging pipeline issues.

Index ¶

• func Discard(s beam.Scope, col beam.PCollection)
• func Head(s beam.Scope, col beam.PCollection, n int) beam.PCollection
• func Print(s beam.Scope, col beam.PCollection) beam.PCollection
• func Printf(s beam.Scope, format string, col beam.PCollection) beam.PCollection

Functions ¶

func Discard ¶

func Discard(s beam.Scope, col beam.PCollection)

Discard is a sink that discards all data.

func Head ¶

func Head(s beam.Scope, col beam.PCollection, n int) beam.PCollection

Head returns the first "n" elements it sees, it doesn't enforce any logic as to what elements they will be.

func Print ¶

func Print(s beam.Scope, col beam.PCollection) beam.PCollection

Print prints out all data. Use with care.

func Printf ¶

func Printf(s beam.Scope, format string, col beam.PCollection) beam.PCollection

Printf prints out all data with custom formatting. The given format string is used as log.Printf(format, elm) for each element. Use with care.

Source Files ¶

debug.shims.go doc.go head.go print.go