Read (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

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

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`.
`static Read.Builder`	`named(String name)` Returns a new `Read` `PTransform` builder with the given name.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2020-02-18.