/dports/databases/pg_citus/citus-10.2.3/src/test/regress/sql/ |
H A D | multi_distribution_metadata.sql | 193 SELECT get_shard_id_for_distribution_column('get_shardid_test_table1', 1); 194 SELECT get_shard_id_for_distribution_column('get_shardid_test_table1', 2); 195 SELECT get_shard_id_for_distribution_column('get_shardid_test_table1', 3); 205 SELECT get_shard_id_for_distribution_column('get_shardid_test_table1', 4); 225 SELECT get_shard_id_for_distribution_column('get_shardid_test_table2', 'a'); 228 SELECT get_shard_id_for_distribution_column('get_shardid_test_table2'); 233 SELECT get_shard_id_for_distribution_column('get_shardid_test_table3', 1); 237 SELECT get_shard_id_for_distribution_column('get_shardid_test_table3', 1); 244 SELECT get_shard_id_for_distribution_column('get_shardid_test_table4'); 248 SELECT get_shard_id_for_distribution_column('get_shardid_test_table4', 1); [all …]
|
H A D | master_copy_shard_placement.sql | 39 get_shard_id_for_distribution_column('data', 'key-1'), 47 get_shard_id_for_distribution_column('data', 'key-1'), 66 get_shard_id_for_distribution_column('data', 'key-1'), 75 get_shard_id_for_distribution_column('data', 'key-1'), 83 WHERE shardid = get_shard_id_for_distribution_column('data', 'key-1') AND nodeport = :worker_2_port; 86 WHERE shardid = get_shard_id_for_distribution_column('history', 'key-1') AND nodeport = :worker_2_p… 107 get_shard_id_for_distribution_column('mx_table', '1'),
|
H A D | drop_column_partitioned_table.sql | 93 sensors_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors', 3)), 94 sensors_2000_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2000', 3)), 95 sensors_2001_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2001', 3)), 96 sensors_2002_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2002', 3)), 97 sensors_2003_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2003', 3)), 98 sensors_2004_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2004', 3)),
|
H A D | multi_transaction_recovery.sql | 209 …d_placement WHERE shardid IN (get_shard_id_for_distribution_column('test_2pcskip', 6),get_shard_id…
|
H A D | local_shard_copy.sql | 57 …WITH local_shard_ids AS (SELECT get_shard_id_for_distribution_column('local_shard_copy.distr… 64 get_shard_id_for_distribution_column IN (SELECT * FROM all_local_shard_ids_on_node);
|
H A D | tableam.sql | 100 get_shard_id_for_distribution_column('test_range_dist', '1'),
|
H A D | citus_local_tables.sql | 257 SELECT get_shard_id_for_distribution_column('citus_local_table_1', 'not_checking_this_arg_for_non_d… 258 SELECT get_shard_id_for_distribution_column('citus_local_table_1');
|
H A D | multi_deparse_function.sql | 223 ALTER FUNCTION pg_catalog.get_shard_id_for_distribution_column(table_name regclass, distribution_va…
|
H A D | local_shard_execution.sql | 80 …WITH local_shard_ids AS (SELECT get_shard_id_for_distribution_column('local_shard_execution.… 87 get_shard_id_for_distribution_column IN (SELECT * FROM all_local_shard_ids_on_node);
|
/dports/databases/pg_citus/citus-10.2.3/src/test/regress/expected/ |
H A D | multi_distribution_metadata.out | 270 get_shard_id_for_distribution_column 276 get_shard_id_for_distribution_column 282 get_shard_id_for_distribution_column 310 get_shard_id_for_distribution_column 326 get_shard_id_for_distribution_column 332 get_shard_id_for_distribution_column 384 get_shard_id_for_distribution_column 390 get_shard_id_for_distribution_column 397 get_shard_id_for_distribution_column 403 get_shard_id_for_distribution_column [all …]
|
H A D | master_copy_shard_placement.out | 47 get_shard_id_for_distribution_column('data', 'key-1'), 56 get_shard_id_for_distribution_column('data', 'key-1'), 74 get_shard_id_for_distribution_column('data', 'key-1'), 82 get_shard_id_for_distribution_column('data', 'key-1'), 94 WHERE shardid = get_shard_id_for_distribution_column('data', 'key-1') AND nodeport = :worker_2_port; 96 WHERE shardid = get_shard_id_for_distribution_column('history', 'key-1') AND nodeport = :worker_2_p… 133 get_shard_id_for_distribution_column('mx_table', '1'),
|
H A D | isolation_blocking_move_multi_shard_commands.out | 14 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 58 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 104 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 150 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 200 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 233 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 283 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 324 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca…
|
H A D | isolation_blocking_move_multi_shard_commands_on_mx.out | 32 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 114 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 196 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca… 276 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca…
|
H A D | drop_column_partitioned_table.out | 146 sensors_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors', 3)), 147 sensors_2000_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2000', 3)), 148 sensors_2001_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2001', 3)), 149 sensors_2002_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2002', 3)), 150 sensors_2003_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2003', 3)), 151 sensors_2004_shardid AS (SELECT * FROM get_shard_id_for_distribution_column('sensors_2004', 3)),
|
H A D | multi_transaction_recovery.out | 385 …d_placement WHERE shardid IN (get_shard_id_for_distribution_column('test_2pcskip', 6),get_shard_id…
|
H A D | citus_local_tables.out | 333 -- get_shard_id_for_distribution_column is supported 334 SELECT get_shard_id_for_distribution_column('citus_local_table_1', 'not_checking_this_arg_for_non_d… 335 get_shard_id_for_distribution_column 340 SELECT get_shard_id_for_distribution_column('citus_local_table_1'); 341 get_shard_id_for_distribution_column
|
H A D | local_shard_copy.out | 78 …WITH local_shard_ids AS (SELECT get_shard_id_for_distribution_column('local_shard_copy.distr… 85 get_shard_id_for_distribution_column IN (SELECT * FROM all_local_shard_ids_on_node);
|
/dports/databases/pg_citus/citus-10.2.3/src/test/regress/spec/ |
H A D | isolation_blocking_move_multi_shard_commands.spec | 15 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard; 37 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca…
|
H A D | isolation_blocking_move_multi_shard_commands_on_mx.spec | 42 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard; 63 …SELECT master_move_shard_placement(get_shard_id_for_distribution_column, 'localhost', 57637, 'loca…
|
H A D | isolation_copy_placement_vs_modification.spec | 10 …SELECT get_shard_id_for_distribution_column('test_repair_placement_vs_modification', 5) INTO selec…
|
H A D | isolation_copy_placement_vs_copy_placement.spec | 10 …SELECT get_shard_id_for_distribution_column('test_hash_table', 5) INTO selected_shard_for_test_tab…
|
H A D | isolation_blocking_move_single_shard_commands.spec | 14 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard;
|
H A D | isolation_blocking_move_single_shard_commands_on_mx.spec | 40 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard;
|
H A D | isolation_rebalancer_deferred_drop.spec | 41 SELECT get_shard_id_for_distribution_column('t1', 15) INTO selected_shard;
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/sql/ |
H A D | citus--8.0-1.sql | 594 CREATE FUNCTION get_shard_id_for_distribution_column(table_name regclass, distribution_value "any" … 597 AS 'MODULE_PATHNAME', $$get_shard_id_for_distribution_column$$; 598 COMMENT ON FUNCTION get_shard_id_for_distribution_column(table_name regclass, distribution_value "a…
|