Package org.apache.iceberg.flink.source
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:
-
Nested Class Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic <T> IcebergSource.Builder<T>
builder()
org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,
IcebergEnumeratorState> createEnumerator
(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumContext) org.apache.flink.api.connector.source.SourceReader<T,
IcebergSourceSplit> createReader
(org.apache.flink.api.connector.source.SourceReaderContext readerContext) static IcebergSource.Builder<org.apache.flink.table.data.RowData>
org.apache.flink.api.connector.source.Boundedness
org.apache.flink.core.io.SimpleVersionedSerializer<IcebergEnumeratorState>
org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,
IcebergEnumeratorState> restoreEnumerator
(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumContext, IcebergEnumeratorState enumState)
-
Method Details
-
getBoundedness
public org.apache.flink.api.connector.source.Boundedness getBoundedness()- Specified by:
getBoundedness
in interfaceorg.apache.flink.api.connector.source.Source<T,
IcebergSourceSplit, IcebergEnumeratorState>
-
createReader
public org.apache.flink.api.connector.source.SourceReader<T,IcebergSourceSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext) - Specified by:
createReader
in interfaceorg.apache.flink.api.connector.source.SourceReaderFactory<T,
IcebergSourceSplit>
-
createEnumerator
public org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumContext) - Specified by:
createEnumerator
in interfaceorg.apache.flink.api.connector.source.Source<T,
IcebergSourceSplit, IcebergEnumeratorState>
-
restoreEnumerator
public org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumContext, IcebergEnumeratorState enumState) - Specified by:
restoreEnumerator
in interfaceorg.apache.flink.api.connector.source.Source<T,
IcebergSourceSplit, IcebergEnumeratorState>
-
getSplitSerializer
- Specified by:
getSplitSerializer
in interfaceorg.apache.flink.api.connector.source.Source<T,
IcebergSourceSplit, IcebergEnumeratorState>
-
getEnumeratorCheckpointSerializer
public org.apache.flink.core.io.SimpleVersionedSerializer<IcebergEnumeratorState> getEnumeratorCheckpointSerializer()- Specified by:
getEnumeratorCheckpointSerializer
in interfaceorg.apache.flink.api.connector.source.Source<T,
IcebergSourceSplit, IcebergEnumeratorState>
-
builder
-
forRowData
-