Home
last modified time | relevance | path

Searched refs:get_shard_id_for_distribution_column (Results 1 – 25 of 33) sorted by relevance

12

/dports/databases/pg_citus/citus-10.2.3/src/test/regress/sql/
H A Dmulti_distribution_metadata.sql193 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 Dmaster_copy_shard_placement.sql39 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 Ddrop_column_partitioned_table.sql93 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 Dmulti_transaction_recovery.sql209 …d_placement WHERE shardid IN (get_shard_id_for_distribution_column('test_2pcskip', 6),get_shard_id…
H A Dlocal_shard_copy.sql57 …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 Dtableam.sql100 get_shard_id_for_distribution_column('test_range_dist', '1'),
H A Dcitus_local_tables.sql257 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 Dmulti_deparse_function.sql223 ALTER FUNCTION pg_catalog.get_shard_id_for_distribution_column(table_name regclass, distribution_va…
H A Dlocal_shard_execution.sql80 …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 Dmulti_distribution_metadata.out270 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 Dmaster_copy_shard_placement.out47 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 Disolation_blocking_move_multi_shard_commands.out14 …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 Disolation_blocking_move_multi_shard_commands_on_mx.out32 …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 Ddrop_column_partitioned_table.out146 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 Dmulti_transaction_recovery.out385 …d_placement WHERE shardid IN (get_shard_id_for_distribution_column('test_2pcskip', 6),get_shard_id…
H A Dcitus_local_tables.out333 -- 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 Dlocal_shard_copy.out78 …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 Disolation_blocking_move_multi_shard_commands.spec15 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 Disolation_blocking_move_multi_shard_commands_on_mx.spec42 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 Disolation_copy_placement_vs_modification.spec10 …SELECT get_shard_id_for_distribution_column('test_repair_placement_vs_modification', 5) INTO selec…
H A Disolation_copy_placement_vs_copy_placement.spec10 …SELECT get_shard_id_for_distribution_column('test_hash_table', 5) INTO selected_shard_for_test_tab…
H A Disolation_blocking_move_single_shard_commands.spec14 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard;
H A Disolation_blocking_move_single_shard_commands_on_mx.spec40 SELECT get_shard_id_for_distribution_column('logical_replicate_placement', 15) INTO selected_shard;
H A Disolation_rebalancer_deferred_drop.spec41 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 Dcitus--8.0-1.sql594 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…

12