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

Refactor AttributeEquivalenceId (#5006)

pull/5559/head^2
Talha Nisanci 2021-12-23 13:19:02 +03:00 committed by GitHub
parent 76176caea7
commit e196d23854
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/planner/relation_restriction_equivalence.c
View File

@ -36,7 +36,7 @@
#include "optimizer/pathnode.h" #include "optimizer/pathnode.h"
static uint32 attributeEquivalenceId = 1; static uint32 AttributeEquivalenceId = 1;
/* /*
@ -292,7 +292,7 @@ SafeToPushdownUnionSubquery(Query *originalQuery,
palloc0(sizeof(AttributeEquivalenceClass)); palloc0(sizeof(AttributeEquivalenceClass));
ListCell *relationRestrictionCell = NULL; ListCell *relationRestrictionCell = NULL;
attributeEquivalence->equivalenceId = attributeEquivalenceId++; attributeEquivalence->equivalenceId = AttributeEquivalenceId++;
/* /*
* Ensure that the partition column is in the same place across all * Ensure that the partition column is in the same place across all
@ -617,7 +617,7 @@ GenerateAllAttributeEquivalences(PlannerRestrictionContext *plannerRestrictionCo
plannerRestrictionContext->joinRestrictionContext; plannerRestrictionContext->joinRestrictionContext;
/* reset the equivalence id counter per call to prevent overflows */ /* reset the equivalence id counter per call to prevent overflows */
attributeEquivalenceId = 1; AttributeEquivalenceId = 1;
List *relationRestrictionAttributeEquivalenceList = List *relationRestrictionAttributeEquivalenceList =
GenerateAttributeEquivalencesForRelationRestrictions(relationRestrictionContext); GenerateAttributeEquivalencesForRelationRestrictions(relationRestrictionContext);
@ -801,7 +801,7 @@ AttributeEquivalenceClassForEquivalenceClass(EquivalenceClass *plannerEqClass,
ListCell *equivilanceMemberCell = NULL; ListCell *equivilanceMemberCell = NULL;
PlannerInfo *plannerInfo = relationRestriction->plannerInfo; PlannerInfo *plannerInfo = relationRestriction->plannerInfo;
attributeEquivalence->equivalenceId = attributeEquivalenceId++; attributeEquivalence->equivalenceId = AttributeEquivalenceId++;
foreach(equivilanceMemberCell, plannerEqClass->ec_members) foreach(equivilanceMemberCell, plannerEqClass->ec_members)
{ {
@ -1183,7 +1183,7 @@ GenerateAttributeEquivalencesForJoinRestrictions(JoinRestrictionContext *
AttributeEquivalenceClass *attributeEquivalence = palloc0( AttributeEquivalenceClass *attributeEquivalence = palloc0(
sizeof(AttributeEquivalenceClass)); sizeof(AttributeEquivalenceClass));
attributeEquivalence->equivalenceId = attributeEquivalenceId++; attributeEquivalence->equivalenceId = AttributeEquivalenceId++;
AddToAttributeEquivalenceClass(attributeEquivalence, AddToAttributeEquivalenceClass(attributeEquivalence,
joinRestriction->plannerInfo, leftVar); joinRestriction->plannerInfo, leftVar);