Uses of Interface
org.apache.flink.connector.file.src.assigners.FileSplitAssigner.Provider
-
Packages that use FileSplitAssigner.Provider Package Description org.apache.flink.connector.file.src org.apache.flink.connector.file.src.impl -
-
Uses of FileSplitAssigner.Provider in org.apache.flink.connector.file.src
Fields in org.apache.flink.connector.file.src declared as FileSplitAssigner.Provider Modifier and Type Field Description static FileSplitAssigner.ProviderFileSource. DEFAULT_SPLIT_ASSIGNERThe default split assigner, a lazy locality-aware assigner.protected FileSplitAssigner.ProviderAbstractFileSource.AbstractFileSourceBuilder. splitAssignerMethods in org.apache.flink.connector.file.src that return FileSplitAssigner.Provider Modifier and Type Method Description FileSplitAssigner.ProviderAbstractFileSource. getAssignerFactory()Methods in org.apache.flink.connector.file.src with parameters of type FileSplitAssigner.Provider Modifier and Type Method Description SELFAbstractFileSource.AbstractFileSourceBuilder. setSplitAssigner(FileSplitAssigner.Provider splitAssigner)Configures theFileSplitAssignerfor the source.Constructors in org.apache.flink.connector.file.src with parameters of type FileSplitAssigner.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 FileSplitAssigner.Provider in org.apache.flink.connector.file.src.impl
Constructors in org.apache.flink.connector.file.src.impl with parameters of type FileSplitAssigner.Provider Constructor Description DynamicFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitT> context, DynamicFileEnumerator.Provider fileEnumeratorFactory, FileSplitAssigner.Provider splitAssignerFactory)
-