Package org.apache.iceberg.flink.source

Class FlinkSource

java.lang.Object

org.apache.iceberg.flink.source.FlinkSource

public class FlinkSource
extends Object

Nested Class Summary

Nested Classes

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

Method Summary

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

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()

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)