DML
MVIEW
SOURCE
UPSTREAM_SINK_UNION
CREATE TABLE authz.subscription_progress ( subscription_name VARCHAR PRIMARY KEY, rw_timestamp BIGINT NOT NULL )