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

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