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.