Package org.apache.iceberg.flink.source.assigner
-
Interface Summary Interface Description SplitAssigner SplitAssigner interface is extracted out as a separate component so that we can plug in different split assignment strategy for different requirements.SplitAssignerFactory -
Class Summary Class Description DefaultSplitAssigner Since all methods are called in the source coordinator thread by enumerator, there is no need for locking.GetSplitResult OrderedSplitAssignerFactory Create default assigner with a comparator that hands out splits where the order of the splits will be defined by theSerializableComparator.SimpleSplitAssignerFactory Create simple assigner that hands out splits without any guarantee in order or locality. -
Enum Summary Enum Description GetSplitResult.Status SplitAssignerType