CREATE FUNCTION pg_catalog.worker_create_schema(jobid bigint, username text) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_create_schema$function$; CREATE FUNCTION pg_catalog.worker_cleanup_job_schema_cache() RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_cleanup_job_schema_cache$function$; CREATE FUNCTION pg_catalog.worker_fetch_foreign_file(text, text, bigint, text[], integer[]) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_fetch_foreign_file$function$; CREATE FUNCTION pg_catalog.worker_fetch_partition_file(bigint, integer, integer, integer, text, integer) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_fetch_partition_file$function$; CREATE FUNCTION pg_catalog.worker_hash_partition_table(bigint, integer, text, text, oid, anyarray) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_hash_partition_table$function$; CREATE FUNCTION pg_catalog.worker_merge_files_into_table(bigint, integer, text[], text[]) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_merge_files_into_table$function$; CREATE FUNCTION pg_catalog.worker_range_partition_table(bigint, integer, text, text, oid, anyarray) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_range_partition_table$function$; CREATE FUNCTION pg_catalog.worker_repartition_cleanup(bigint) RETURNS void LANGUAGE c STRICT AS 'MODULE_PATHNAME', $function$worker_repartition_cleanup$function$; DROP FUNCTION pg_catalog.citus_split_shard_by_split_points( shard_id bigint, split_points text[], node_ids integer[], split_mode citus.split_mode); DROP FUNCTION pg_catalog.worker_split_copy( source_shard_id bigint, splitCopyInfos citus.split_copy_info[]); DROP TYPE citus.split_mode; DROP TYPE citus.split_copy_info; #include "../../../columnar/sql/downgrades/columnar--11.1-1--11.0-3.sql" DROP FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, OUT global_pid int8); #include "../udfs/get_all_active_transactions/11.0-1.sql"