public class SimpleSplitAssignerFactory extends java.lang.Object implements SplitAssignerFactory
Constructor and Description |
---|
SimpleSplitAssignerFactory() |
Modifier and Type | Method and Description |
---|---|
SimpleSplitAssigner |
createAssigner() |
SimpleSplitAssigner |
createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState) |
public SimpleSplitAssigner createAssigner()
createAssigner
in interface SplitAssignerFactory
public SimpleSplitAssigner createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)
createAssigner
in interface SplitAssignerFactory