Read

public class Read
extends java.lang.Object

A PTransform for reading from a Source.

Usage example:

 Pipeline p = Pipeline.create();
 p.apply(Read.from(new MySource().withFoo("foo").withBar("bar")));

Nested Classes
Modifier and Type	Class and Description
`static class`	`Read.Bounded<T>` `PTransform` that reads from a `BoundedSource`.
`static class`	`Read.Builder` Helper class for building `Read` transforms.
`static class`	`Read.Unbounded<T>` `PTransform` that reads from a `UnboundedSource`.

Constructors
Constructor and Description
`Read()`

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static <T> Read.Bounded<T>`	`from(BoundedSource<T> source)` Returns a new `Read.Bounded` `PTransform` reading from the given `BoundedSource`.
`static <T> Read.Unbounded<T>`	`from(UnboundedSource<T,?> source)` Returns a new `Read.Unbounded` `PTransform` reading from the given `UnboundedSource`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Class Read