Package org.apache.iceberg.flink.source
Class IcebergSource<T>
- java.lang.Object
-
- org.apache.iceberg.flink.source.IcebergSource<T>
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>
@Experimental public class IcebergSource<T> extends java.lang.Object implements org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
IcebergSource.Builder<T>
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <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>
forRowData()
org.apache.flink.api.connector.source.Boundedness
getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<IcebergEnumeratorState>
getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumContext, IcebergEnumeratorState enumState)
-
-
-
Method Detail
-
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.Source<T,IcebergSourceSplit,IcebergEnumeratorState>
-
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
public org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit> 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
public static <T> IcebergSource.Builder<T> builder()
-
forRowData
public static IcebergSource.Builder<org.apache.flink.table.data.RowData> forRowData()
-
-