Package org.apache.flink.connector.file.src.reader
-
Interface Summary Interface Description BulkFormat<T,SplitT extends FileSourceSplit> TheBulkFormatreads and decodes batches of records at a time.BulkFormat.Reader<T> The actual reader that reads the batches of records.BulkFormat.RecordIterator<T> An iterator over records with their position in the file.StreamFormat<T> A reader format that reads individual records from a stream.StreamFormat.Reader<T> The actual reader that reads the records. -
Class Summary Class Description SimpleStreamFormat<T> A simple version of theStreamFormat, for formats that are not splittable.TextLineInputFormat A reader format that text lines from a file.TextLineInputFormat.Reader The actual reader for theTextLineInputFormat.