创建 SQL 作业

CREATE TABLE `Data_Input` ( --步骤 1 ：创建数据源表（Source） Data_Input
    age BIGINT,
    score BIGINT
) WITH (
    'connector' = 'datagen',
    'rows-per-second'='100',          -- 每秒产生的数据条数

    'fields.age.kind'='random',       -- 无界的随机数
    'fields.age.min'='1',           -- 随机数的最小值
    'fields.age.max'='100',         -- 随机数的最大值

    'fields.score.kind'='random',        -- 无界的随机数
    'fields.score.min'='1',              -- 随机数的最小值
    'fields.score.max'='1000'            -- 随机数的最大值
);

CREATE TABLE `Data_Output` ( --步骤 2 ：创建数据结果表（Sink） Data_Output
    `avg_age` BIGINT,
    `avg_score` BIGINT
) WITH (
    'connector' = 'blackhole'
);

INSERT INTO `Data_Output`   --步骤 3 ： 将数据源表（Source） Data_Intput 中的 age 和 score 取平均数之后存储于数据结果表（Sink） Data_Output
SELECT AVG(age), AVG(score) FROM `Data_Input`;