Package org.apache.iceberg.flink.source.assigner
package org.apache.iceberg.flink.source.assigner
-
ClassDescriptionSince all methods are called in the source coordinator thread by enumerator, there is no need for locking.Create default assigner with a comparator that hands out splits where the order of the splits will be defined by the
SerializableComparator.Create simple assigner that hands out splits without any guarantee in order or locality.SplitAssigner interface is extracted out as a separate component so that we can plug in different split assignment strategy for different requirements.