Searched refs:leftShardId (Results 1 – 9 of 9) sorted by relevance
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
| H A D | shardinterval_utils.c | 120 int64 leftShardId = leftInterval->shardId; in CompareShardIntervalsById() local
124 if (leftShardId > rightShardId) in CompareShardIntervalsById()
128 else if (leftShardId < rightShardId) in CompareShardIntervalsById()
148 int64 leftShardId = left->shardId; in CompareShardPlacementsByShardId() local
152 if (leftShardId > rightShardId) in CompareShardPlacementsByShardId()
156 else if (leftShardId < rightShardId) in CompareShardPlacementsByShardId()
178 int64 leftShardId = leftRelationShard->shardId; in CompareRelationShards() local
189 else if (leftShardId > rightShardId) in CompareRelationShards()
193 else if (leftShardId < rightShardId) in CompareRelationShards()
|
| H A D | colocation_utils.c | 341 uint64 leftShardId = leftInterval->shardId; in ErrorIfShardPlacementsNotColocated() local
354 leftShardId); in ErrorIfShardPlacementsNotColocated()
365 leftShardId, leftRelationName, in ErrorIfShardPlacementsNotColocated()
396 leftShardId, leftRelationName, in ErrorIfShardPlacementsNotColocated()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/ |
| H A D | colocation_utils.c | 66 uint32 leftShardId = PG_GETARG_UINT32(0); in shards_colocated() local
68 ShardInterval *leftShard = LoadShardInterval(leftShardId); in shards_colocated()
|
| /dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
| H A D | relay_utility.h | 43 uint64 leftShardId,
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | table.c | 2821 uint64 leftShardId = leftShardInterval->shardId; in InterShardDDLTaskList() local
2826 leftShardId, escapedLeftSchemaName, rightShardId, in InterShardDDLTaskList()
2836 task->anchorShardId = leftShardId; in InterShardDDLTaskList()
2898 uint64 leftShardId = leftShardInterval->shardId; in SetInterShardDDLTaskPlacementList() local
2899 task->taskPlacementList = ActiveShardPlacementListOnGroup(leftShardId, in SetInterShardDDLTaskPlacementList()
2904 uint64 leftShardId = leftShardInterval->shardId; in SetInterShardDDLTaskPlacementList() local
2905 task->taskPlacementList = ActiveShardPlacementList(leftShardId); in SetInterShardDDLTaskPlacementList()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/worker/ |
| H A D | worker_data_fetch_protocol.c | 417 uint64 leftShardId = PG_GETARG_INT64(0); in worker_apply_inter_shard_ddl_command() local
429 RelayEventExtendNamesForInterShardCommands(ddlCommandNode, leftShardId, in worker_apply_inter_shard_ddl_command()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/relay/ |
| H A D | relay_event_utility.c | 649 RelayEventExtendNamesForInterShardCommands(Node *parseTree, uint64 leftShardId, in RelayEventExtendNamesForInterShardCommands() argument
723 RelayEventExtendNames(parseTree, leftShardSchemaName, leftShardId); in RelayEventExtendNamesForInterShardCommands()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
| H A D | multi_router_planner.c | 3867 int64 leftShardId = leftValue->shardId; in CompareInsertValuesByShardId() local
3872 if (leftShardId > rightShardId) in CompareInsertValuesByShardId()
3876 else if (leftShardId < rightShardId) in CompareInsertValuesByShardId()
|
| H A D | multi_physical_planner.c | 5510 uint64 leftShardId = leftTask->anchorShardId; in CompareTasksByShardId() local
5514 if (leftShardId > rightShardId) in CompareTasksByShardId()
5518 else if (leftShardId < rightShardId) in CompareTasksByShardId()
|