Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.io
Class Read
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.io.Read
-
public class Read extends Object
APTransform
for reading from aSource
.Usage example:
Pipeline p = Pipeline.create(); p.apply(Read.from(new MySource().withFoo("foo").withBar("bar")) .named("foobar"));
-
-
Nested Class Summary
Nested Classes Modifier and Type Class and Description static class
Read.Bounded<T>
PTransform
that reads from aBoundedSource
.static class
Read.Builder
Helper class for buildingRead
transforms.static class
Read.Unbounded<T>
PTransform
that reads from aUnboundedSource
.
-
Constructor Summary
Constructors Constructor and Description Read()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method and Description static <T> Read.Bounded<T>
from(BoundedSource<T> source)
Returns a newRead.Bounded
PTransform
reading from the givenBoundedSource
.static <T> Read.Unbounded<T>
from(UnboundedSource<T,?> source)
Returns a newRead.Unbounded
PTransform
reading from the givenUnboundedSource
.static Read.Builder
named(String name)
Returns a newRead
PTransform
builder with the given name.
-
-
-
Method Detail
-
named
public static Read.Builder named(String name)
Returns a newRead
PTransform
builder with the given name.
-
from
public static <T> Read.Bounded<T> from(BoundedSource<T> source)
Returns a newRead.Bounded
PTransform
reading from the givenBoundedSource
.
-
from
public static <T> Read.Unbounded<T> from(UnboundedSource<T,?> source)
Returns a newRead.Unbounded
PTransform
reading from the givenUnboundedSource
.
-
-