Uses of Interface
org.apache.flink.connector.file.src.enumerate.FileEnumerator.Provider
-
Packages that use FileEnumerator.Provider Package Description org.apache.flink.connector.file.src org.apache.flink.connector.file.src.enumerate -
-
Uses of FileEnumerator.Provider in org.apache.flink.connector.file.src
Fields in org.apache.flink.connector.file.src declared as FileEnumerator.Provider Modifier and Type Field Description static FileEnumerator.ProviderFileSource. DEFAULT_NON_SPLITTABLE_FILE_ENUMERATORThe default file enumerator used for non-splittable formats.static FileEnumerator.ProviderFileSource. DEFAULT_SPLITTABLE_FILE_ENUMERATORThe default file enumerator used for splittable formats.protected FileEnumerator.ProviderAbstractFileSource.AbstractFileSourceBuilder. fileEnumeratorMethods in org.apache.flink.connector.file.src that return FileEnumerator.Provider Modifier and Type Method Description protected FileEnumerator.ProviderAbstractFileSource. getEnumeratorFactory()Methods in org.apache.flink.connector.file.src with parameters of type FileEnumerator.Provider Modifier and Type Method Description SELFAbstractFileSource.AbstractFileSourceBuilder. setFileEnumerator(FileEnumerator.Provider fileEnumerator)Configures theFileEnumeratorfor the source.Constructors in org.apache.flink.connector.file.src with parameters of type FileEnumerator.Provider Constructor Description AbstractFileSource(org.apache.flink.core.fs.Path[] inputPaths, FileEnumerator.Provider fileEnumerator, FileSplitAssigner.Provider splitAssigner, BulkFormat<T,SplitT> readerFormat, ContinuousEnumerationSettings continuousEnumerationSettings)AbstractFileSourceBuilder(org.apache.flink.core.fs.Path[] inputPaths, BulkFormat<T,SplitT> readerFormat, FileEnumerator.Provider defaultFileEnumerator, FileSplitAssigner.Provider defaultSplitAssigner) -
Uses of FileEnumerator.Provider in org.apache.flink.connector.file.src.enumerate
Subinterfaces of FileEnumerator.Provider in org.apache.flink.connector.file.src.enumerate Modifier and Type Interface Description static interfaceDynamicFileEnumerator.ProviderFactory for theDynamicFileEnumerator.
-