SimpleSplitAssignerFactory

java.lang.Object

org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory

All Implemented Interfaces:: Serializable, SplitAssignerFactory

public class SimpleSplitAssignerFactory extends Object implements SplitAssignerFactory

Create simple assigner that hands out splits without any guarantee in order or locality.

See Also:

Constructor Summary

Constructors

Constructor

Description

SimpleSplitAssignerFactory()
Method Summary

Modifier and Type

Method

Description

SplitAssigner

createAssigner()

SplitAssigner

createAssigner(Collection<IcebergSourceSplitState> assignerState)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- SimpleSplitAssignerFactory
  
  public SimpleSplitAssignerFactory()
Method Details
- createAssigner
  
  public SplitAssigner createAssigner()
  
  Specified by:
  
  createAssigner in interface SplitAssignerFactory
- createAssigner
  
  public SplitAssigner createAssigner(Collection<IcebergSourceSplitState> assignerState)
  
  Specified by:
  
  createAssigner in interface SplitAssignerFactory