Package org.apache.flink.connector.file.src.assigners
-
Interface Summary Interface Description FileSplitAssigner TheFileSplitAssigner
is responsible for deciding what split should be processed next by which node.FileSplitAssigner.Provider Factory for theFileSplitAssigner
, to allow theFileSplitAssigner
to be eagerly initialized and to not be serializable. -
Class Summary Class Description LocalityAwareSplitAssigner AFileSplitAssigner
that assigns to each host preferably splits that are local, before assigning splits that are not local.SimpleSplitAssigner TheSimpleSplitAssigner
hands out splits in a random order, without any consideration for order or locality.