Package org.apache.iceberg.flink.source
Class FlinkSource
- java.lang.Object
-
- org.apache.iceberg.flink.source.FlinkSource
-
public class FlinkSource extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FlinkSource.Builder
Source builder to buildDataStream
.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static FlinkSource.Builder
forRowData()
Initialize aFlinkSource.Builder
to read the data from iceberg table.static boolean
isBounded(java.util.Map<java.lang.String,java.lang.String> properties)
-
-
-
Method Detail
-
forRowData
public static FlinkSource.Builder forRowData()
Initialize aFlinkSource.Builder
to read the data from iceberg table. Equivalent toTableScan
. See more options inScanContext
.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(java.util.Map<java.lang.String,java.lang.String> properties)
-
-