数据湖探索 DLI-BlackHole结果表:示例

时间:2024-12-27 10:34:30

示例

通过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_0392.html