Module create_sql 

Decoders for catalog create_sql strings.

Each function parses a persisted create_sql and returns a JSON value with the fields a builtin catalog view projects. Errors are human-readable strings.

Functions

connection_details

Extracts connection-detail metadata from a catalog create_sql.

item_details

Parses a catalog create_sql string into a JSON object.

item_references

Extracts the catalog item references from a catalog create_sql string as a JSONB object.

kafka_source_details

Extracts kafka source configuration (topic, group id prefix, connection id) from a catalog create_sql. Returns:

postgres_source_details

Extracts postgres source publication details (slot, timeline_id) from a catalog create_sql. Returns:

source_export_details

Extracts source-export (source table) metadata from a catalog create_sql.