Package org.apache.flink.connector.file.src.impl

Class Summary

Class	Description
ContinuousFileSplitEnumerator	A continuously monitoring enumerator.
DynamicFileSplitEnumerator<SplitT extends FileSourceSplit>	A SplitEnumerator implementation that supports dynamic filtering.
FileRecords<T>	A collection of records for one file split.
FileSourceReader<T,SplitT extends FileSourceSplit>	A SourceReader that read records from FileSourceSplit.
StaticFileSplitEnumerator	A SplitEnumerator implementation for bounded / batch FileSource input.
StreamFormatAdapter<T>	Adapter to turn a StreamFormat into a BulkFormat.
StreamFormatAdapter.Reader<T>	The reader adapter, from StreamFormat.Reader to BulkFormat.Reader.