Read (Google Cloud Dataflow SDK 0.4.150710 API)

public class Read
extends Object

A PTransform for reading from a Source.

Usage example:

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

Nested Classes
Modifier and Type	Class and Description
`static class`	`Read.Bound<T>` Implementation of the `Read` `PTransform` builder.

Constructors
Constructor and Description
`Read()`

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

Class Read