数据湖探索 DLI-FileSystem源表:示例

时间：2024-12-11 08:41:28

数据湖探索 DLI

示例

从obs表作为数据源读取数据，输出到print connector。

CREATE TABLE obs_source(
   name string,
   num INT,
   `file.path` STRING NOT NULL METADATA
) WITH (
   'connector' = 'filesystem',
   'path' = 'obs://demo/sink_parquent_obs',
   'format' = 'parquet',
   'source.monitor-interval'='1 h'
);


CREATE TABLE print (
   name string,
   num INT,
   path  STRING
) WITH (
   'connector' = 'print'
);

insert into print
select * from obs_source;

上一篇：数据湖探索 DLI-FileSystem源表:语法格式

下一篇：数据湖探索 DLI-FileSystem源表:语法格式