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:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IcebergSource.Builder<T>

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Specified by:

getBoundedness in interface org.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 interface org.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 interface org.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 interface org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<T,IcebergSourceSplit,IcebergEnumeratorState>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<IcebergEnumeratorState> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.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()