Uses of Interface
org.apache.flink.connector.file.src.assigners.FileSplitAssigner

Packages that use FileSplitAssigner

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

Uses of FileSplitAssigner in org.apache.flink.connector.file.src.assigners

Classes in org.apache.flink.connector.file.src.assigners that implement FileSplitAssigner

Modifier and Type	Class	Description
class	LocalityAwareSplitAssigner	A FileSplitAssigner that assigns to each host preferably splits that are local, before assigning splits that are not local.
class	SimpleSplitAssigner	The SimpleSplitAssigner hands out splits in a random order, without any consideration for order or locality.

Methods in org.apache.flink.connector.file.src.assigners that return FileSplitAssigner

Modifier and Type	Method	Description
FileSplitAssigner	FileSplitAssigner.Provider.create(Collection<FileSourceSplit> initialSplits)	Creates a new FileSplitAssigner that starts with the given set of initial splits.

Uses of FileSplitAssigner in org.apache.flink.connector.file.src.impl

Constructors in org.apache.flink.connector.file.src.impl with parameters of type FileSplitAssigner

Constructor	Description
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileSourceSplit> context, FileEnumerator enumerator, FileSplitAssigner splitAssigner, org.apache.flink.core.fs.Path[] paths, Collection<org.apache.flink.core.fs.Path> alreadyDiscoveredPaths, long discoveryInterval)
StaticFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileSourceSplit> context, FileSplitAssigner splitAssigner)