Package org.apache.iceberg.flink.source

Class 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 build DataStream.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static FlinkSource.Builder forRowData()
      Initialize a FlinkSource.Builder to read the data from iceberg table.
      static boolean isBounded​(java.util.Map<java.lang.String,​java.lang.String> properties)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

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