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