You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/04/28 16:34:48 UTC
[1/2] beam git commit: Fix Javadoc warnings
Repository: beam
Updated Branches:
refs/heads/master bff84e27c -> ccfff5f82
Fix Javadoc warnings
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34054ab2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34054ab2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34054ab2
Branch: refs/heads/master
Commit: 34054ab27a53546571b4b687629a0997875479dc
Parents: bff84e2
Author: Isma�l Mej�a <ie...@apache.org>
Authored: Wed Apr 26 17:43:53 2017 +0200
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Apr 28 09:34:31 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java | 2 +-
.../io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/34054ab2/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
index 20fc4d9..7f89c1c 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
@@ -179,7 +179,7 @@ public abstract class FileBasedSource<T> extends OffsetBasedSource<T> {
* @param fileMetadata file backing the new {@code FileBasedSource}.
* @param start starting byte offset of the new {@code FileBasedSource}.
* @param end ending byte offset of the new {@code FileBasedSource}. May be Long.MAX_VALUE,
- * in which case it will be inferred using {@link #getMaxEndOffset}.
+ * in which case it will be inferred using {@link FileBasedSource#getMaxEndOffset}.
*/
protected abstract FileBasedSource<T> createForSubrangeOfFile(
Metadata fileMetadata, long start, long end);
http://git-wip-us.apache.org/repos/asf/beam/blob/34054ab2/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java b/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java
index ee349a9..5a3fcd9 100644
--- a/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java
+++ b/sdks/java/io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java
@@ -149,7 +149,7 @@ public abstract class Sink<T> implements Serializable, HasDisplayData {
* not interfere with the output of other Writers, as a bundle may be executed many times for
* fault tolerance. See {@link Sink} for more information about bundle ids.
*
- * <p></p>The window and paneInfo arguments are populated when windowed writes are requested.
+ * <p>The window and paneInfo arguments are populated when windowed writes are requested.
* shard and numbShards are populated for the case of static sharding. In cases where the
* runner is dynamically picking sharding, shard and numShards might both be set to -1.
*/
[2/2] beam git commit: This closes #2705
Posted by da...@apache.org.
This closes #2705
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ccfff5f8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ccfff5f8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ccfff5f8
Branch: refs/heads/master
Commit: ccfff5f82a56d9027541b17ed38a7590afae8134
Parents: bff84e2 34054ab
Author: Davor Bonaci <da...@google.com>
Authored: Fri Apr 28 09:34:35 2017 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Apr 28 09:34:35 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java | 2 +-
.../io/hdfs/src/main/java/org/apache/beam/sdk/io/hdfs/Sink.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------