数据湖探索 DLI-BlackHole:示例

时间:2024-04-18 20:33:03

示例

通过DataGen源表产生数据,BlackHole结果表接收传来的数据。

create table datagenSource (
 user_id string,
 user_name string,
 user_age int
) with (
 'connector' = 'datagen',
 'rows-per-second'='1'
);
create table blackholeSink (
 user_id string,
 user_name string,
 user_age int
) with (
 'connector' = 'blackhole'
);
insert into blackholeSink select * from datagenSource;
support.huaweicloud.com/sqlref-flink-dli/dli_08_15029.html