1-- print version above 11 (eg. 12 and above) 2SHOW server_version \gset 3SELECT substring(:'server_version', '\d+')::int > 11 AS version_above_eleven; 4 version_above_eleven 5--------------------------------------------------------------------- 6 t 7(1 row) 8 9-- list all postgres objects belonging to the citus extension 10SELECT pg_catalog.pg_describe_object(classid, objid, 0) AS description 11FROM pg_catalog.pg_depend, pg_catalog.pg_extension e 12WHERE refclassid = 'pg_catalog.pg_extension'::pg_catalog.regclass 13 AND refobjid = e.oid 14 AND deptype = 'e' 15 AND e.extname='citus' 16ORDER BY 1; 17 description 18--------------------------------------------------------------------- 19 access method columnar 20 event trigger citus_cascade_to_partition 21 function alter_columnar_table_reset(regclass,boolean,boolean,boolean,boolean) 22 function alter_columnar_table_set(regclass,integer,integer,name,integer) 23 function alter_distributed_table(regclass,text,integer,text,boolean) 24 function alter_old_partitions_set_access_method(regclass,timestamp with time zone,name) 25 function alter_role_if_exists(text,text) 26 function alter_table_set_access_method(regclass,text) 27 function any_value(anyelement) 28 function any_value_agg(anyelement,anyelement) 29 function array_cat_agg(anyarray) 30 function assign_distributed_transaction_id(integer,bigint,timestamp with time zone) 31 function authinfo_valid(text) 32 function broadcast_intermediate_result(text,text) 33 function check_distributed_deadlocks() 34 function citus_activate_node(text,integer) 35 function citus_add_inactive_node(text,integer,integer,noderole,name) 36 function citus_add_local_table_to_metadata(regclass,boolean) 37 function citus_add_node(text,integer,integer,noderole,name) 38 function citus_add_rebalance_strategy(name,regproc,regproc,regproc,real,real,real) 39 function citus_add_secondary_node(text,integer,text,integer,name) 40 function citus_blocking_pids(integer) 41 function citus_cleanup_orphaned_shards() 42 function citus_conninfo_cache_invalidate() 43 function citus_copy_shard_placement(bigint,text,integer,text,integer,boolean,citus.shard_transfer_mode) 44 function citus_create_restore_point(text) 45 function citus_disable_node(text,integer) 46 function citus_dist_local_group_cache_invalidate() 47 function citus_dist_node_cache_invalidate() 48 function citus_dist_object_cache_invalidate() 49 function citus_dist_partition_cache_invalidate() 50 function citus_dist_placement_cache_invalidate() 51 function citus_dist_shard_cache_invalidate() 52 function citus_dist_stat_activity() 53 function citus_drain_node(text,integer,citus.shard_transfer_mode,name) 54 function citus_drop_all_shards(regclass,text,text,boolean) 55 function citus_drop_trigger() 56 function citus_executor_name(integer) 57 function citus_extradata_container(internal) 58 function citus_finish_pg_upgrade() 59 function citus_get_active_worker_nodes() 60 function citus_internal.columnar_ensure_am_depends_catalog() 61 function citus_internal.downgrade_columnar_storage(regclass) 62 function citus_internal.find_groupid_for_node(text,integer) 63 function citus_internal.pg_dist_node_trigger_func() 64 function citus_internal.pg_dist_rebalance_strategy_trigger_func() 65 function citus_internal.pg_dist_shard_placement_trigger_func() 66 function citus_internal.refresh_isolation_tester_prepared_statement() 67 function citus_internal.replace_isolation_tester_func() 68 function citus_internal.restore_isolation_tester_func() 69 function citus_internal.upgrade_columnar_storage(regclass) 70 function citus_internal_add_partition_metadata(regclass,"char",text,integer,"char") 71 function citus_internal_add_placement_metadata(bigint,integer,bigint,integer,bigint) 72 function citus_internal_add_shard_metadata(regclass,bigint,"char",text,text) 73 function citus_internal_delete_shard_metadata(bigint) 74 function citus_internal_update_placement_metadata(bigint,integer,integer) 75 function citus_internal_update_relation_colocation(oid,integer) 76 function citus_isolation_test_session_is_blocked(integer,integer[]) 77 function citus_json_concatenate(json,json) 78 function citus_json_concatenate_final(json) 79 function citus_jsonb_concatenate(jsonb,jsonb) 80 function citus_jsonb_concatenate_final(jsonb) 81 function citus_local_disk_space_stats() 82 function citus_move_shard_placement(bigint,text,integer,text,integer,citus.shard_transfer_mode) 83 function citus_node_capacity_1(integer) 84 function citus_prepare_pg_upgrade() 85 function citus_query_stats() 86 function citus_relation_size(regclass) 87 function citus_remote_connection_stats() 88 function citus_remove_node(text,integer) 89 function citus_server_id() 90 function citus_set_coordinator_host(text,integer,noderole,name) 91 function citus_set_default_rebalance_strategy(text) 92 function citus_set_node_property(text,integer,text,boolean) 93 function citus_shard_allowed_on_node_true(bigint,integer) 94 function citus_shard_cost_1(bigint) 95 function citus_shard_cost_by_disk_size(bigint) 96 function citus_shard_sizes() 97 function citus_stat_statements() 98 function citus_stat_statements_reset() 99 function citus_table_is_visible(oid) 100 function citus_table_size(regclass) 101 function citus_text_send_as_jsonb(text) 102 function citus_total_relation_size(regclass,boolean) 103 function citus_truncate_trigger() 104 function citus_unmark_object_distributed(oid,oid,integer) 105 function citus_update_node(integer,text,integer,boolean,integer) 106 function citus_update_shard_statistics(bigint) 107 function citus_update_table_statistics(regclass) 108 function citus_validate_rebalance_strategy_functions(regproc,regproc,regproc) 109 function citus_version() 110 function citus_worker_stat_activity() 111 function column_name_to_column(regclass,text) 112 function column_to_column_name(regclass,text) 113 function columnar.columnar_handler(internal) 114 function coord_combine_agg(oid,cstring,anyelement) 115 function coord_combine_agg_ffunc(internal,oid,cstring,anyelement) 116 function coord_combine_agg_sfunc(internal,oid,cstring,anyelement) 117 function create_distributed_function(regprocedure,text,text) 118 function create_distributed_table(regclass,text,citus.distribution_type,text,integer) 119 function create_intermediate_result(text,text) 120 function create_reference_table(regclass) 121 function create_time_partitions(regclass,interval,timestamp with time zone,timestamp with time zone) 122 function distributed_tables_colocated(regclass,regclass) 123 function drop_old_time_partitions(regclass,timestamp with time zone) 124 function dump_global_wait_edges() 125 function dump_local_wait_edges() 126 function fetch_intermediate_results(text[],text,integer) 127 function fix_all_partition_shard_index_names() 128 function fix_partition_shard_index_names(regclass) 129 function fix_pre_citus10_partitioned_table_constraint_names() 130 function fix_pre_citus10_partitioned_table_constraint_names(regclass) 131 function get_all_active_transactions() 132 function get_colocated_shard_array(bigint) 133 function get_colocated_table_array(regclass) 134 function get_current_transaction_id() 135 function get_global_active_transactions() 136 function get_missing_time_partition_ranges(regclass,interval,timestamp with time zone,timestamp with time zone) 137 function get_rebalance_progress() 138 function get_rebalance_table_shards_plan(regclass,real,integer,bigint[],boolean,name,real) 139 function get_shard_id_for_distribution_column(regclass,"any") 140 function isolate_tenant_to_new_shard(regclass,"any",text) 141 function json_cat_agg(json) 142 function jsonb_cat_agg(jsonb) 143 function lock_relation_if_exists(text,text) 144 function lock_shard_metadata(integer,bigint[]) 145 function lock_shard_resources(integer,bigint[]) 146 function master_activate_node(text,integer) 147 function master_add_inactive_node(text,integer,integer,noderole,name) 148 function master_add_node(text,integer,integer,noderole,name) 149 function master_add_secondary_node(text,integer,text,integer,name) 150 function master_append_table_to_shard(bigint,text,text,integer) 151 function master_apply_delete_command(text) 152 function master_copy_shard_placement(bigint,text,integer,text,integer,boolean,citus.shard_transfer_mode) 153 function master_create_empty_shard(text) 154 function master_disable_node(text,integer) 155 function master_drain_node(text,integer,citus.shard_transfer_mode,name) 156 function master_get_active_worker_nodes() 157 function master_get_new_placementid() 158 function master_get_new_shardid() 159 function master_get_table_ddl_events(text) 160 function master_get_table_metadata(text) 161 function master_move_shard_placement(bigint,text,integer,text,integer,citus.shard_transfer_mode) 162 function master_remove_distributed_table_metadata_from_workers(regclass,text,text) 163 function master_remove_node(text,integer) 164 function master_remove_partition_metadata(regclass,text,text) 165 function master_run_on_worker(text[],integer[],text[],boolean) 166 function master_set_node_property(text,integer,text,boolean) 167 function master_unmark_object_distributed(oid,oid,integer) 168 function master_update_node(integer,text,integer,boolean,integer) 169 function master_update_shard_statistics(bigint) 170 function master_update_table_statistics(regclass) 171 function notify_constraint_dropped() 172 function poolinfo_valid(text) 173 function read_intermediate_result(text,citus_copy_format) 174 function read_intermediate_results(text[],citus_copy_format) 175 function rebalance_table_shards(regclass,real,integer,bigint[],citus.shard_transfer_mode,boolean,name) 176 function recover_prepared_transactions() 177 function relation_is_a_known_shard(regclass) 178 function remove_local_tables_from_metadata() 179 function replicate_reference_tables() 180 function replicate_table_shards(regclass,integer,integer,bigint[],citus.shard_transfer_mode) 181 function role_exists(name) 182 function run_command_on_colocated_placements(regclass,regclass,text,boolean) 183 function run_command_on_placements(regclass,text,boolean) 184 function run_command_on_shards(regclass,text,boolean) 185 function run_command_on_workers(text,boolean) 186 function shard_name(regclass,bigint) 187 function start_metadata_sync_to_node(text,integer) 188 function stop_metadata_sync_to_node(text,integer,boolean) 189 function time_partition_range(regclass) 190 function truncate_local_data_after_distributing_table(regclass) 191 function undistribute_table(regclass,boolean) 192 function update_distributed_table_colocation(regclass,text) 193 function worker_append_table_to_shard(text,text,text,integer) 194 function worker_apply_inter_shard_ddl_command(bigint,text,bigint,text,text) 195 function worker_apply_sequence_command(text) 196 function worker_apply_sequence_command(text,regtype) 197 function worker_apply_shard_ddl_command(bigint,text) 198 function worker_apply_shard_ddl_command(bigint,text,text) 199 function worker_change_sequence_dependency(regclass,regclass,regclass) 200 function worker_cleanup_job_schema_cache() 201 function worker_create_or_alter_role(text,text,text) 202 function worker_create_or_replace_object(text) 203 function worker_create_schema(bigint,text) 204 function worker_create_truncate_trigger(regclass) 205 function worker_drop_distributed_table(text) 206 function worker_fetch_foreign_file(text,text,bigint,text[],integer[]) 207 function worker_fetch_partition_file(bigint,integer,integer,integer,text,integer) 208 function worker_fix_partition_shard_index_names(regclass, text, text) 209 function worker_fix_pre_citus10_partitioned_table_constraint_names(regclass,bigint,text) 210 function worker_hash("any") 211 function worker_hash_partition_table(bigint,integer,text,text,oid,anyarray) 212 function worker_last_saved_explain_analyze() 213 function worker_merge_files_into_table(bigint,integer,text[],text[]) 214 function worker_nextval(regclass) 215 function worker_partial_agg(oid,anyelement) 216 function worker_partial_agg_ffunc(internal) 217 function worker_partial_agg_sfunc(internal,oid,anyelement) 218 function worker_partition_query_result(text,text,integer,citus.distribution_type,text[],text[],boolean) 219 function worker_partitioned_relation_size(regclass) 220 function worker_partitioned_relation_total_size(regclass) 221 function worker_partitioned_table_size(regclass) 222 function worker_range_partition_table(bigint,integer,text,text,oid,anyarray) 223 function worker_record_sequence_dependency(regclass,regclass,name) 224 function worker_repartition_cleanup(bigint) 225 function worker_save_query_explain_analyze(text,jsonb) 226 schema citus 227 schema citus_internal 228 schema columnar 229 sequence columnar.storageid_seq 230 sequence pg_dist_colocationid_seq 231 sequence pg_dist_groupid_seq 232 sequence pg_dist_node_nodeid_seq 233 sequence pg_dist_placement_placementid_seq 234 sequence pg_dist_shardid_seq 235 table citus.pg_dist_object 236 table columnar.chunk 237 table columnar.chunk_group 238 table columnar.options 239 table columnar.stripe 240 table pg_dist_authinfo 241 table pg_dist_colocation 242 table pg_dist_local_group 243 table pg_dist_node 244 table pg_dist_node_metadata 245 table pg_dist_partition 246 table pg_dist_placement 247 table pg_dist_poolinfo 248 table pg_dist_rebalance_strategy 249 table pg_dist_shard 250 table pg_dist_transaction 251 type citus.distribution_type 252 type citus.shard_transfer_mode 253 type citus_copy_format 254 type noderole 255 view citus_dist_stat_activity 256 view citus_lock_waits 257 view citus_schema.citus_tables 258 view citus_shard_indexes_on_worker 259 view citus_shards 260 view citus_shards_on_worker 261 view citus_stat_statements 262 view citus_worker_stat_activity 263 view pg_dist_shard_placement 264 view time_partitions 265(246 rows) 266 267