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

Minor code clean-up

pull/2724/head
exialin 2019-05-18 10:58:18 +08:00 committed by Marco Slot
parent b31fbcb28d
commit 59e54de54d
3 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3452,7 +3452,6 @@ JoinSequenceArray(List *rangeTableFragmentsList, Query *jobQuery, List *depended
uint32 rangeTableCount = (uint32) list_length(rangeTableList); uint32 rangeTableCount = (uint32) list_length(rangeTableList);
uint32 sequenceNodeSize = sizeof(JoinSequenceNode); uint32 sequenceNodeSize = sizeof(JoinSequenceNode);
uint32 joinedTableCount = 0; uint32 joinedTableCount = 0;
List *joinedTableList = NIL;
List *joinExprList = NIL; List *joinExprList = NIL;
ListCell *joinExprCell = NULL; ListCell *joinExprCell = NULL;
uint32 firstRangeTableId = 1; uint32 firstRangeTableId = 1;
@ -3574,7 +3573,6 @@ JoinSequenceArray(List *rangeTableFragmentsList, Query *jobQuery, List *depended
nextJoinSequenceNode->joiningRangeTableId = NON_PRUNABLE_JOIN; nextJoinSequenceNode->joiningRangeTableId = NON_PRUNABLE_JOIN;
} }
joinedTableList = lappend_int(joinedTableList, nextRangeTableId);
joinedTableCount++; joinedTableCount++;
} }

2
src/backend/distributed/utils/metadata_cache.c
View File

@ -167,7 +167,7 @@ static bool workerNodeHashValid = false;
/* default value is -1, for coordinator it's 0 and for worker nodes > 0 */ /* default value is -1, for coordinator it's 0 and for worker nodes > 0 */
static int32 LocalGroupId = -1; static int32 LocalGroupId = -1;
/* built first time through in InitializePartitionCache */ /* built first time through in InitializeDistTableCache */
static ScanKeyData DistPartitionScanKey[1]; static ScanKeyData DistPartitionScanKey[1];
static ScanKeyData DistShardScanKey[1]; static ScanKeyData DistShardScanKey[1];

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

@ -63,7 +63,7 @@ typedef struct
/* /*
* Comparator for partition interval type (different from * Comparator for partition interval type (different from
* shardValueCompareFunction if hash-partitioned), NULL if * shardColumnCompareFunction if hash-partitioned), NULL if
* DISTRIBUTE_BY_NONE. * DISTRIBUTE_BY_NONE.
*/ */
FmgrInfo *shardIntervalCompareFunction; FmgrInfo *shardIntervalCompareFunction;