Class OrderedSplitAssignerFactory
- java.lang.Object
-
- org.apache.iceberg.flink.source.assigner.OrderedSplitAssignerFactory
-
- All Implemented Interfaces:
java.io.Serializable
,SplitAssignerFactory
public class OrderedSplitAssignerFactory extends java.lang.Object implements SplitAssignerFactory
Create default assigner with a comparator that hands out splits where the order of the splits will be defined by theSerializableComparator
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description OrderedSplitAssignerFactory(SerializableComparator<IcebergSourceSplit> comparator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SplitAssigner
createAssigner()
SplitAssigner
createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)
-
-
-
Constructor Detail
-
OrderedSplitAssignerFactory
public OrderedSplitAssignerFactory(SerializableComparator<IcebergSourceSplit> comparator)
-
-
Method Detail
-
createAssigner
public SplitAssigner createAssigner()
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-
createAssigner
public SplitAssigner createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-
-