Class IcebergSource<T>

java.lang.Object
org.apache.iceberg.flink.source.IcebergSource<T>
All Implemented Interfaces:
Serializable, org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,IcebergSourceSplit>

@Experimental public class IcebergSource<T> extends Object implements org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>
See Also: