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 0bb407f05618e..7bb1598e26ebb 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 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. *

* 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 true - * 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. */