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>

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()	Deprecated. since 1.7.0.
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 <T> IcebergSource.Builder<T>	forOutputType(RowDataConverter<T> converter)	Create a source builder that would convert RowData to the output type T.
static IcebergSource.Builder<org.apache.flink.table.data.RowData>	forRowData()	Create a source builder for RowData output type.
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

Methods inherited from interface org.apache.flink.api.connector.source.Source

declareWatermarks

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

@Deprecated
public static <T> IcebergSource.Builder<T> builder()

Deprecated.

since 1.7.0. Will be removed in 2.0.0; useforRowData() or forOutputType(RowDataConverter) instead

Create a source builder.

forRowData

public static IcebergSource.Builder<org.apache.flink.table.data.RowData> forRowData()

Create a source builder for RowData output type.

forOutputType

public static <T> IcebergSource.Builder<T> forOutputType(RowDataConverter<T> converter)

Create a source builder that would convert RowData to the output type T.

Type Parameters:

T - output type

Parameters:

converter - convert RowData to output type T

Returns:

an IcebergSource builder