Package org.apache.beam.runners.spark.io

Class ConsoleIO.Write

java.lang.Object

org.apache.beam.runners.spark.io.ConsoleIO.Write

Enclosing class:

ConsoleIO

public static final class ConsoleIO.Write
extends Object

Write to console.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConsoleIO.Write.Unbound<T>	PTransform writing PCollection to the console.

Method Summary

Modifier and Type	Method	Description
static <T> ConsoleIO.Write.Unbound<T>	out()	Prints 10 elements from the PCollection to the console.
static <T> ConsoleIO.Write.Unbound<T>	out(int num)	Prints num elements from the PCollection to stdout.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

out

public static <T> ConsoleIO.Write.Unbound<T> out()

Prints 10 elements from the PCollection to the console.

out

public static <T> ConsoleIO.Write.Unbound<T> out(int num)

Prints num elements from the PCollection to stdout.