Class FlinkSource


  • @Deprecated
    public class FlinkSource
    extends java.lang.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 Detail

      • 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​(java.util.Map<java.lang.String,​java.lang.String> properties)
        Deprecated.