Iceberg

Description

Read data from Iceberg.

提示

Engine Supported and plugin name

• Spark: Iceberg
• Flink

Options

name	type	required	default value
common-options		yes	-
path	string	yes	-
pre_sql	string	yes	-
snapshot-id	long	no	-
as-of-timestamp	long	no	-

Refer to iceberg read options for more configurations.

common-options

Source plugin common parameters, please refer to Source Plugin for details

path

Iceberg table location.

pre_sql

SQL statements queried from iceberg table. Note that the table name is result_table_name configuration

snapshot-id

Snapshot ID of the table snapshot to read

as-of-timestamp

A timestamp in milliseconds; the snapshot used will be the snapshot current at this time.

Example

iceberg {
    path = "hdfs://localhost:9000/iceberg/warehouse/db/table"
    result_table_name = "my_source"
    pre_sql="select * from my_source where dt = '2019-01-01'"
}