Documentation
¶
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 ¶
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.
Source Files
Click to show internal directories.
Click to hide internal directories.