Package org.apache.beam.sdk.io

Class Read

java.lang.Object

org.apache.beam.sdk.io.Read

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")));
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	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.

Constructor Summary

Constructors

Constructor	Description
Read()

Method Summary

Modifier and Type	Method	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

Constructor Details

Read

public Read()

Method Details

from

public static <T> Read.Bounded<T> from(BoundedSource<T> source)

Returns a new Read.Bounded PTransform reading from the given BoundedSource.

from

public static <T> Read.Unbounded<T> from(UnboundedSource<T,?> source)

Returns a new Read.Unbounded PTransform reading from the given UnboundedSource.