external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update ColocatedShardPlacementList() function name to 

ColocatedShardIntervalList() which was intented.
pull/838/head
Onder Kalaci 2016-10-04 09:51:42 +03:00
parent 09e3d5fd47
commit 0993f2fb2c
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/test/colocation_utils.c
View File

@ -119,7 +119,7 @@ get_colocated_shard_array(PG_FUNCTION_ARGS)
ShardInterval *shardInterval = LoadShardInterval(shardId);
ArrayType *colocatedShardsArrayType = NULL;
List *colocatedShardList = ColocatedShardPlacementList(shardInterval);
List *colocatedShardList = ColocatedShardIntervalList(shardInterval);
ListCell *colocatedShardCell = NULL;
int colocatedShardCount = list_length(colocatedShardList);
Datum *colocatedShardsDatumArray = palloc0(colocatedShardCount * sizeof(Datum));

4
src/backend/distributed/utils/colocation_utils.c
View File

@ -162,13 +162,13 @@ ColocatedTableList(Oid distributedTableId)
/*
* ColocatedShardPlacementList function returns list of shard intervals which are
* ColocatedShardIntervalList function returns list of shard intervals which are
* co-located with given shard. If given shard is belong to append or range distributed
* table, co-location is not valid for that shard. Therefore such shard is only co-located
* with itself.
*/
List *
ColocatedShardPlacementList(ShardInterval *shardInterval)
ColocatedShardIntervalList(ShardInterval *shardInterval)
{
Oid distributedTableId = shardInterval->relationId;
List *colocatedShardList = NIL;

2
src/include/distributed/colocation_utils.h
View File

@ -22,6 +22,6 @@ extern bool TablesColocated(Oid leftDistributedTableId, Oid rightDistributedTabl
extern bool ShardsColocated(ShardInterval *leftShardInterval,
ShardInterval *rightShardInterval);
extern List * ColocatedTableList(Oid distributedTableId);
extern List * ColocatedShardPlacementList(ShardInterval *shardInterval);
extern List * ColocatedShardIntervalList(ShardInterval *shardInterval);
#endif /* COLOCATION_UTILS_H_ */