>>>pipeline_explain.txt

>>>flink-sql-no-functions.sql
CREATE TABLE `Customer` (
  `customerid` BIGINT NOT NULL,
  `email` STRING NOT NULL,
  `name` STRING NOT NULL,
  `lastUpdated` AS `NOW`(),
  WATERMARK FOR `lastUpdated` AS `lastUpdated` - INTERVAL '0.001' SECOND
)
WITH (
  'connector' = 'datagen',
  'fields.customerid.kind' = 'sequence',
  'fields.customerid.start' = '1',
  'fields.customerid.end' = '10',
  'fields.email.length' = '15',
  'fields.name.length' = '10',
  'rows-per-second' = '5'
);
CREATE TABLE IF NOT EXISTS `customer_id_count` (
  `customerid` BIGINT,
  `numEntries` BIGINT,
  PRIMARY KEY (`customerid`) NOT ENFORCED
)
WITH (
  'connector' = 'print',
  'print-identifier' = '${SUPER_SECRET}'
);
CREATE TEMPORARY TABLE IF NOT EXISTS `unused_print_sink` (
  `num` INTEGER,
  `text` STRING
)
WITH (
  'connector' = 'print',
  'print-identifier' = '${NON_EXISTING_ENV_VAR}'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `customer_id_count`
SELECT `customerid`, COUNT(*) AS `numEntries`
 FROM `Customer`
 GROUP BY `customerid`
;
END
