org.apache.iceberg.flink.source.assigner

Interface SplitAssignerFactory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

SimpleSplitAssignerFactory

public interface SplitAssignerFactory
extends java.io.Serializable

Method Summary

Modifier and Type	Method and Description
SplitAssigner	createAssigner()
SplitAssigner	createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)

Method Detail

createAssigner

SplitAssigner createAssigner()

createAssigner

SplitAssigner createAssigner(java.util.Collection<IcebergSourceSplitState> assignerState)