Skip to content

Commit

Permalink
add comments
Browse files Browse the repository at this point in the history
  • Loading branch information
englefly committed Sep 7, 2023
1 parent c630e3f commit f98a363
Showing 1 changed file with 10 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -133,6 +133,16 @@ public PhysicalProperties visitPhysicalFileScan(PhysicalFileScan fileScan, PlanC
return PhysicalProperties.STORAGE_ANY;
}

/**
* TODO return ANY after refactor coordinator
* return STORAGE_ANY not ANY, in order to generate distribute on jdbc scan.
* select * from (select * from external.T) as A union all (select * from external.T)
* if visitPhysicalJdbcScan returns ANY, the plan is
* union
* |--- JDBCSCAN
* +--- JDBCSCAN
* this breaks coordinator assumption that one fragment has at most only one scan.
*/
@Override
public PhysicalProperties visitPhysicalJdbcScan(PhysicalJdbcScan jdbcScan, PlanContext context) {
return PhysicalProperties.STORAGE_ANY;
Expand Down

0 comments on commit f98a363

Please sign in to comment.