>>>pipeline_explain.txt
=== MyView
ID:          default_catalog.default_database.MyView
Type:        state
Stage:       flink
Primary key: val
Timestamp:   -
Row count:   ~2
---
Schema:
 - val: INTEGER NOT NULL
Annotations:
 - sort: [0 ASC-nulls-first]

>>>flink-sql-no-functions.sql
CREATE VIEW `MyView`
AS
SELECT *
FROM (VALUES ROW(1),
   ROW(2)) AS `t` (`val`);
CREATE TABLE `MyView_1` (
  `val` INTEGER NOT NULL,
  PRIMARY KEY (`val`) NOT ENFORCED
)
WITH (
  'connector' = 'jdbc-sqrl',
  'driver' = 'org.postgresql.Driver',
  'password' = '${POSTGRES_PASSWORD}',
  'table-name' = 'MyView',
  'url' = 'jdbc:postgresql://${POSTGRES_AUTHORITY}',
  'username' = '${POSTGRES_USERNAME}'
);
EXECUTE STATEMENT SET BEGIN
INSERT INTO `default_catalog`.`default_database`.`MyView_1`
SELECT *
 FROM `default_catalog`.`default_database`.`MyView`
;
END
>>>postgres-schema.sql
CREATE TABLE IF NOT EXISTS "MyView" ("val" INTEGER NOT NULL, PRIMARY KEY ("val"))
>>>postgres-views.sql

