>>>pipeline_explain.txt
=== Src
ID:          default_catalog.default_database.Src
Type:        stream
Stage:       flink
Primary key: -
Timestamp:   -
Row count:   ~1e8
---
Schema:
 - val: INTEGER NOT NULL
Inputs:
 - default_catalog.default_database.Src__base

=== sink_a
ID:          tables.sink_a
Type:        export
Stage:       flink
Connector:   print
---
Inputs:
 - default_catalog.default_database.Src

=== sink_b
ID:          tables.sink_b
Type:        export
Stage:       flink
Connector:   print
---
Inputs:
 - default_catalog.default_database.Src

>>>flink-sql-no-functions-0.sql
CREATE TABLE `Src` (
  `val` INTEGER NOT NULL
)
WITH (
  'connector' = 'datagen',
  'number-of-rows' = '5',
  'rows-per-second' = '5',
  'fields.val.kind' = 'random',
  'fields.val.min' = '1',
  'fields.val.max' = '5'
);
CREATE TABLE `TableA` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableB` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkA_ex1` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableA`
SELECT *
 FROM `Src`
;
INSERT INTO `default_catalog`.`default_database`.`SinkA_ex1`
 SELECT *
  FROM `default_catalog`.`default_database`.`Src`
 ;
 END
>>>flink-sql-no-functions-1.sql
CREATE TABLE `Src` (
  `val` INTEGER NOT NULL
)
WITH (
  'connector' = 'datagen',
  'number-of-rows' = '5',
  'rows-per-second' = '5',
  'fields.val.kind' = 'random',
  'fields.val.min' = '1',
  'fields.val.max' = '5'
);
CREATE TABLE `TableA` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableB` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkA_ex1` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkB_ex2` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableB`
SELECT *
 FROM `Src`
;
INSERT INTO `default_catalog`.`default_database`.`SinkB_ex2`
 SELECT *
  FROM `default_catalog`.`default_database`.`Src`
 ;
 END
>>>flink-sql-no-functions-2.sql
CREATE TABLE `Src` (
  `val` INTEGER NOT NULL
)
WITH (
  'connector' = 'datagen',
  'number-of-rows' = '5',
  'rows-per-second' = '5',
  'fields.val.kind' = 'random',
  'fields.val.min' = '1',
  'fields.val.max' = '5'
);
CREATE TABLE `TableA` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableB` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkA_ex1` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkB_ex2` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableC` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableC`
SELECT *
 FROM `Src`
;
END
>>>flink-sql-no-functions.sql
CREATE TABLE `Src` (
  `val` INTEGER NOT NULL
)
WITH (
  'connector' = 'datagen',
  'number-of-rows' = '5',
  'rows-per-second' = '5',
  'fields.val.kind' = 'random',
  'fields.val.min' = '1',
  'fields.val.max' = '5'
);
CREATE TABLE `TableA` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableB` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkA_ex1` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `SinkB_ex2` (
  `val` INTEGER
)
WITH (
  'connector' = 'print'
);
CREATE TABLE `TableC` (
  `recordCount` INTEGER
)
WITH (
  'connector' = 'print'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableA`
SELECT *
 FROM `Src`
;
INSERT INTO `default_catalog`.`default_database`.`SinkA_ex1`
 SELECT *
  FROM `default_catalog`.`default_database`.`Src`
 ;
 END;
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableB`
SELECT *
 FROM `Src`
;
INSERT INTO `default_catalog`.`default_database`.`SinkB_ex2`
 SELECT *
  FROM `default_catalog`.`default_database`.`Src`
 ;
 END;
EXECUTE STATEMENT SET BEGIN
INSERT INTO `TableC`
SELECT *
 FROM `Src`
;
END
