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

CoPartitionedTables works with hash partitioning as well

pull/431/head
Brian Cloutier 2016-04-06 06:00:39 -07:00
parent 01bdab891b
commit 2e68203b6b
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/backend/distributed/planner/multi_logical_optimizer.c
View File

@ -139,8 +139,10 @@ static bool JoinOnPartitionColumn(Query *query);
static void ErrorIfUnsupportedShardDistribution(Query *query);
static List * RelationIdList(Query *query);
static bool CoPartitionedTables(Oid firstRelationId, Oid secondRelationId);
static bool ShardIntervalsEqual(FmgrInfo *comparisonFunction, ShardInterval *firstInterval,
static bool ShardIntervalsEqual(FmgrInfo *comparisonFunction,
ShardInterval *firstInterval,
ShardInterval *secondInterval);
static void ErrorIfUnsupportedFilters(Query *subquery);
static bool EqualOpExpressionLists(List *firstOpExpressionList,
List *secondOpExpressionList);
@ -3473,7 +3475,6 @@ RelationIdList(Query *query)
return relationIdList;
}
/*
* CoPartitionedTables checks if given two distributed tables have 1-to-1 shard
* partitioning. It uses shard interval array that are sorted on interval minimum
@ -3506,7 +3507,15 @@ CoPartitionedTables(Oid firstRelationId, Oid secondRelationId)
return true;
}
typeId = sortedFirstIntervalArray[0].valueTypeId;
if (firstTableCache->partitionMethod == DISTRIBUTE_BY_HASH)
{
typeId = INT4OID;
}
else
{
typeId = sortedFirstIntervalArray[0].valueTypeId;
}
comparisonFunction = GetFunctionInfo(typeId, BTREE_AM_OID, BTORDER_PROC);
for (intervalIndex = 0; intervalIndex < firstListShardCount; intervalIndex++)

2
src/backend/distributed/planner/multi_physical_planner.c
View File

@ -2102,7 +2102,7 @@ SubquerySqlTaskList(Job *job)
* traffic.
*/
if (anchorRangeTableId == 0 || prunedTableSize > maxPrunedTableSize){
maxTableSize = prunedTableSize;
maxPrunedTableSize = prunedTableSize;
anchorRangeTableId = tableId;
}