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 java.lang.Object

Write to console.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
static <T> ConsoleIO.Write.Unbound<T>	out() Prints 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 Detail

out

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

Prints 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.