You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/03/31 01:10:35 UTC
[1/2] beam git commit: Fixed: small documentation issue in HDFS IO
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 <pe...@protonmail.com>
Authored: Sun Mar 26 11:20:40 2017 -0400
Committer: Dan Halperin <dh...@google.com>
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>
*
[2/2] beam git commit: This closes #2346
Posted by dh...@apache.org.
This closes #2346
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b1c287bd
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b1c287bd
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b1c287bd
Branch: refs/heads/master
Commit: b1c287bd5946de70e4848775bbf400e787392d27
Parents: 7057d1e aa42067
Author: Dan Halperin <dh...@google.com>
Authored: Thu Mar 30 18:10:29 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Mar 30 18:10:29 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(-)
----------------------------------------------------------------------