1  CREATE TABLE debezium_source (
 2        min BIGINT,
 3        max BIGINT,
 4        sum BIGINT,
 5        count BIGINT,
 6        avg DOUBLE
 7      ) WITH (
 8        connector = 'single_file',
 9        path = '$input_dir/aggregate_updates.json',
10        format = 'debezium_json',
11        type = 'source'
12      );
13  
14  CREATE TABLE output (
15        min BIGINT,
16        max BIGINT,
17        sum BIGINT,
18        count BIGINT,
19        avg DOUBLE
20      ) WITH (
21        connector = 'single_file',
22        path = '$output_path',
23        format = 'debezium_json',
24        type = 'sink'
25      );
26  
27      INSERT INTO output 
28      SELECT *
29      FROM debezium_source