Class TextLineInputFormat.Reader
- java.lang.Object
-
- org.apache.flink.connector.file.src.reader.TextLineInputFormat.Reader
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,StreamFormat.Reader<String>
- Enclosing class:
- TextLineInputFormat
@PublicEvolving public static final class TextLineInputFormat.Reader extends Object implements StreamFormat.Reader<String>
The actual reader for theTextLineInputFormat
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes the reader to release all resources.String
read()
Reads the next record.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.connector.file.src.reader.StreamFormat.Reader
getCheckpointedPosition
-
-
-
-
Method Detail
-
read
@Nullable public String read() throws IOException
Description copied from interface:StreamFormat.Reader
Reads the next record. Returnsnull
when the input has reached its end.- Specified by:
read
in interfaceStreamFormat.Reader<String>
- Throws:
IOException
-
close
public void close() throws IOException
Description copied from interface:StreamFormat.Reader
Closes the reader to release all resources.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceStreamFormat.Reader<String>
- Throws:
IOException
-
-