tencent cloud

CREATE TABLE `Data_Input` ( --Step 1. Create the data source "Data_Input"
    age BIGINT,
    score BIGINT
) WITH (
    'connector' = 'datagen',
    'rows-per-second'='100',                  -- The number of data records generated per second

    'fields.age.kind'='random',       -- A random number without range
    'fields.f_random.min'='1',               -- ‍The minimum random number
    'fields.f_random.max'='100',             -- The maximum random number

    'fields.score.kind'='random',        -- A random number without range
    'fields.score.min'='1',              -- ‍The minimum random number
    'fields.score.max'='1000'            -- The maximum random number
);

CREATE TABLE `Data_Output` ( -- Step 2. Create the output data table "Data_Output"
    `avg_age` BIGINT,
    `avg_score` BIGINT
) WITH (
    'connector' = 'blackhole'
);

INSERT INTO `Data_Output`   -- Step 3. Calculate the average of the "age" and "score" values in "Data_Input" and store the results in "Data_Output"
SELECT AVG(age), AVG(score) FROM `Data_Input`;