Repository: beam Updated Branches: refs/heads/master 7057d1e22 -> b1c287bd5
Fixed: small documentation issue in HDFS IO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa420678 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aa420678 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aa420678 Branch: refs/heads/master Commit: aa4206787c79272ec9af5f96f6170c61dd585fea Parents: 7057d1e Author: peay <[email protected]> Authored: Sun Mar 26 11:20:40 2017 -0400 Committer: Dan Halperin <[email protected]> Committed: Thu Mar 30 18:10:27 2017 -0700 ---------------------------------------------------------------------- sdks/java/io/hdfs/README.md | 6 +++--- .../main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/aa420678/sdks/java/io/hdfs/README.md ---------------------------------------------------------------------- diff --git a/sdks/java/io/hdfs/README.md b/sdks/java/io/hdfs/README.md index 1c6134f..3a734f2 100644 --- a/sdks/java/io/hdfs/README.md +++ b/sdks/java/io/hdfs/README.md @@ -31,13 +31,13 @@ A `HDFSFileSource` can be read from using the ```java HDFSFileSource<K, V> source = HDFSFileSource.from(path, MyInputFormat.class, MyKey.class, MyValue.class); -PCollection<KV<MyKey, MyValue>> records = Read.from(mySource); +PCollection<KV<MyKey, MyValue>> records = pipeline.apply(Read.from(mySource)); ``` Alternatively, the `readFrom` method is a convenience method that returns a read transform. For example: ```java -PCollection<KV<MyKey, MyValue>> records = HDFSFileSource.readFrom(path, - MyInputFormat.class, MyKey.class, MyValue.class); +PCollection<KV<MyKey, MyValue>> records = pipeline.apply(HDFSFileSource.readFrom(path, + MyInputFormat.class, MyKey.class, MyValue.class)); ``` http://git-wip-us.apache.org/repos/asf/beam/blob/aa420678/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java b/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java index 357a527..e317c6e 100644 --- a/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java +++ b/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java @@ -90,7 +90,7 @@ import org.slf4j.LoggerFactory; * {@code * HDFSFileSource<K, V> source = HDFSFileSource.from(path, MyInputFormat.class, * MyKey.class, MyValue.class); - * PCollection<KV<MyKey, MyValue>> records = Read.from(mySource); + * PCollection<KV<MyKey, MyValue>> records = pipeline.apply(Read.from(mySource)); * } * </pre> *
