企业网站推广服务协议,湖州 网站建设公司,开发公司管理软件,网络建设工程师一#xff1a;catalog
是存储元数据的地方。
二#xff1a;表中增加catalog地址’
当我们映射iceberg表的时候#xff0c;增加了地址#xff0c;就会成功映射到表
CREATE CATALOG dk_empower WITH(typeiceberg,catalog-typehadoop,warehousehdfs://cluster/iceberg/war…一catalog
是存储元数据的地方。
二表中增加catalog地址’
当我们映射iceberg表的时候增加了地址就会成功映射到表
CREATE CATALOG dk_empower WITH(typeiceberg,catalog-typehadoop,warehousehdfs://cluster/iceberg/warehouse/iceberg_hadoop/dk_empower,property-version1
); create table dwd_dk_event_log (p_dt string,process_name string,stage int,stage_name string,event_id string,event_name string,flag int,state int,ts timestamp_ltz,ts1 as CAST(ts AS TIMESTAMP_LTZ(3)),WATERMARK FOR ts1 AS ts1 - INTERVAL 5 SECOND -- 在t_s上定义5 秒延迟的 watermark
) with (connectoriceberg,catalog-namedk_empower,catalog-databaseods,catalog-tabledwd_dk_event_log,streamingtrue,monitor-interval2s,catalog-typehadoop,warehousehdfs://cluster/iceberg/warehouse/iceberg_hadoop/dk_empower--start-snapshot-id);
