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