Class SimpleSplitAssignerFactory
- java.lang.Object
-
- org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory
-
- All Implemented Interfaces:
java.io.Serializable
,SplitAssignerFactory
public class SimpleSplitAssignerFactory extends java.lang.Object implements SplitAssignerFactory
Create simple assigner that hands out splits without any guarantee in order or locality.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SimpleSplitAssignerFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SimpleSplitAssigner
createAssigner()
SimpleSplitAssigner
createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)
-
-
-
Method Detail
-
createAssigner
public SimpleSplitAssigner createAssigner()
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-
createAssigner
public SimpleSplitAssigner createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-
-