Package org.apache.iceberg.flink.source

Class FlinkSource

java.lang.Object

org.apache.iceberg.flink.source.FlinkSource

@Deprecated
public class FlinkSource
extends Object

Deprecated.

since 1.7.0, will be removed in 2.0.0. Use IcebergSource instead, which implement the newer FLIP-27 source interface. This class implements the old SourceFunction that has been marked as deprecated in Flink since Aug 2023.

Flink source builder for old SourceFunction implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FlinkSource.Builder	Deprecated. Source builder to build DataStream.

Method Summary

Modifier and Type	Method	Description
static FlinkSource.Builder	forRowData()	Deprecated. Initialize a FlinkSource.Builder to read the data from iceberg table.
static boolean	isBounded(Map<String,String> properties)	Deprecated.

Methods inherited from class java.lang.Object

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

Method Details

forRowData

public static FlinkSource.Builder forRowData()

Deprecated.

Initialize a FlinkSource.Builder to read the data from iceberg table. Equivalent to TableScan. See more options in ScanContext.

The Source can be read static data in bounded mode. It can also continuously check the arrival of new data and read records incrementally.

• Without startSnapshotId: Bounded
• With startSnapshotId and with endSnapshotId: Bounded
• With startSnapshotId (-1 means unbounded preceding) and Without endSnapshotId: Unbounded

Returns:

FlinkSource.Builder to connect the iceberg table.

isBounded

public static boolean isBounded(Map<String,String> properties)

Deprecated.