debug

package
v2.28.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 13, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Discard

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

Discard is a sink that discards all data.

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.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL