FlinkSql读取iceberg表

要在 FlinkSQL 中读取 iceberg 表，你需要使用 iceberg-catalog 和 iceberg-flink 库。

首先，你需要在 FlinkSQL 中注册 iceberg-catalog，如下所示：

CREATE CATALOG iceberg_catalog WITH (
  'type'='iceberg',
  'catalog-type'='hadoop',
  'catalog-impl'='org.apache.iceberg.hadoop.HadoopCatalog',
  'warehouse'='hdfs://<your-hdfs-warehouse-path>'
);

然后，你需要使用 iceberg-catalog 和 iceberg-flink 库来读取 iceberg 表。以下是一个示例查询：

SELECT * FROM TABLE (
  iceberg_catalog.`<your-table-name>`
  (format 'iceberg')
);

注意：在上面的查询中，你需要将 `<your-table-name>` 替换为你要查询的 iceberg 表的名称。