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
GetSplitResult
SimpleSplitAssigner	Since all methods are called in the source coordinator thread by enumerator, there is no need for locking.
SimpleSplitAssignerFactory	Create simple assigner that hands out splits without any guarantee in order or locality.

Enum Summary

Enum	Description
GetSplitResult.Status
SplitAssignerType