Repository: flink Updated Branches: refs/heads/release-0.9 c7e868416 -> 633276139
[docs] Fix Javadocs of RuntimeContext parallel subtask index Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63327613 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/63327613 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/63327613 Branch: refs/heads/release-0.9 Commit: 6332761390d877ffd4db4565d460a57ad1449d5a Parents: c7e8684 Author: Ufuk Celebi <[email protected]> Authored: Thu Jul 16 16:46:17 2015 +0200 Committer: Ufuk Celebi <[email protected]> Committed: Sat Jul 18 11:10:13 2015 +0200 ---------------------------------------------------------------------- .../org/apache/flink/api/common/functions/RuntimeContext.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/63327613/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java index f68d2b0..49f6633 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java @@ -55,10 +55,10 @@ public interface RuntimeContext { int getNumberOfParallelSubtasks(); /** - * Gets the number of the parallel subtask. The numbering starts from 1 and goes up to the parallelism, - * as returned by {@link #getNumberOfParallelSubtasks()}. + * Gets the number of this parallel subtask. The numbering starts from 0 and goes up to + * parallelism-1 (parallelism as returned by {@link #getNumberOfParallelSubtasks()}). * - * @return The number of the parallel subtask. + * @return The index of the parallel subtask. */ int getIndexOfThisSubtask();
