Class SimpleSplitAssignerFactory
java.lang.Object
org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory
- All Implemented Interfaces:
Serializable
,SplitAssignerFactory
Create simple assigner that hands out splits without any guarantee in order or locality.
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioncreateAssigner
(Collection<IcebergSourceSplitState> assignerState)
-
Constructor Details
-
SimpleSplitAssignerFactory
public SimpleSplitAssignerFactory()
-
-
Method Details
-
createAssigner
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-
createAssigner
- Specified by:
createAssigner
in interfaceSplitAssignerFactory
-