public class FlinkSource
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
FlinkSource.Builder
Source builder to build
DataStream . |
Modifier and Type | Method and 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) |
public static FlinkSource.Builder forRowData()
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.
FlinkSource.Builder
to connect the iceberg table.public static boolean isBounded(java.util.Map<java.lang.String,java.lang.String> properties)