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 <[email protected]> Authored: Wed Apr 26 17:43:53 2017 +0200 Committer: Davor Bonaci <[email protected]> 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. */
