Package org.apache.iceberg.flink.source
Class FlinkSource
- java.lang.Object
-
- org.apache.iceberg.flink.source.FlinkSource
-
@Deprecated public class FlinkSource extends java.lang.Object
Deprecated.since 1.7.0, will be removed in 2.0.0. UseIcebergSource
instead, which implement the newer FLIP-27 source interface. This class implements the oldSourceFunction
that has been marked as deprecated in Flink since Aug 2023./** Flink source builder for oldSourceFunction
implementation.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FlinkSource.Builder
Deprecated.Source builder to buildDataStream
.
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static FlinkSource.Builder
forRowData()
Deprecated.Initialize aFlinkSource.Builder
to read the data from iceberg table.static boolean
isBounded(java.util.Map<java.lang.String,java.lang.String> properties)
Deprecated.
-
-
-
Method Detail
-
forRowData
public static FlinkSource.Builder forRowData()
Deprecated.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)
Deprecated.
-
-