Repository: flink Updated Branches: refs/heads/master 1f45c8734 -> 7beb0110a
[FLINK-2233] Update InputF nextRecord javadocs This closes #2233. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7beb0110 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7beb0110 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7beb0110 Branch: refs/heads/master Commit: 7beb0110a5c7da5b17d03e3095cc12df28fbd8f9 Parents: 1f45c87 Author: zentol <ches...@apache.org> Authored: Wed Nov 18 11:32:25 2015 +0100 Committer: zentol <ches...@apache.org> Committed: Wed Nov 18 17:13:00 2015 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/flink/api/common/io/InputFormat.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7beb0110/flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java index 0bb407f..7bb1598 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java @@ -130,15 +130,12 @@ public interface InputFormat<OT, T extends InputSplit> extends InputSplitSource< boolean reachedEnd() throws IOException; /** - * Tries to read the next pair from the input. By using the return value invalid records in the - * input can be skipped. + * Reads the next record from the input. * <p> * When this method is called, the input format it guaranteed to be opened. * * @param reuse Object that may be reused. - * @return Indicates whether the record could be successfully read. A return value of <i>true</i> - * indicates that the read was successful, a return value of false indicates that the - * current record was not read successfully and should be skipped. + * @return Read record. * * @throws IOException Thrown, if an I/O error occurred. */
