Uses of Interface
org.apache.flink.connector.file.src.reader.StreamFormat.Reader

Packages that use StreamFormat.Reader

Package	Description
org.apache.flink.connector.file.src.reader
org.apache.flink.formats.csv

Uses of StreamFormat.Reader in org.apache.flink.connector.file.src.reader

Classes in org.apache.flink.connector.file.src.reader that implement StreamFormat.Reader

Modifier and Type	Class	Description
static class	TextLineInputFormat.Reader	The actual reader for the TextLineInputFormat.

Methods in org.apache.flink.connector.file.src.reader that return StreamFormat.Reader

Modifier and Type	Method	Description
abstract StreamFormat.Reader<T>	SimpleStreamFormat.createReader(Configuration config, FSDataInputStream stream)	Creates a new reader.
StreamFormat.Reader<T>	SimpleStreamFormat.createReader(Configuration config, FSDataInputStream stream, long fileLen, long splitEnd)
StreamFormat.Reader<T>	StreamFormat.createReader(Configuration config, FSDataInputStream stream, long fileLen, long splitEnd)	Creates a new reader to read in this format.
StreamFormat.Reader<T>	SimpleStreamFormat.restoreReader(Configuration config, FSDataInputStream stream, long restoredOffset, long fileLen, long splitEnd)
StreamFormat.Reader<T>	StreamFormat.restoreReader(Configuration config, FSDataInputStream stream, long restoredOffset, long fileLen, long splitEnd)	Restores a reader from a checkpointed position.

Uses of StreamFormat.Reader in org.apache.flink.formats.csv

Methods in org.apache.flink.formats.csv that return StreamFormat.Reader

Modifier and Type	Method	Description
StreamFormat.Reader<T>	CsvReaderFormat.createReader(Configuration config, FSDataInputStream stream)