TsukiokaKogane commented on code in PR #63850:
URL: https://github.com/apache/doris/pull/63850#discussion_r3361754292
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindRelation.java:
##########
@@ -243,6 +253,13 @@ private LogicalPlan makeOlapScan(TableIf table,
UnboundRelation unboundRelation,
CollectionUtils.isEmpty(partIds) ? ((OlapTable)
table).getPartitionIds() : partIds, indexId,
preAggStatus, CollectionUtils.isEmpty(partIds) ?
ImmutableList.of() : partIds,
unboundRelation.getHints(),
unboundRelation.getTableSample(), ImmutableList.of());
+ } else if (isChangeRead(unboundRelation)) {
+ OlapTable olapTable = (OlapTable) table;
+ RowBinlogTableWrapper wrapper = new
RowBinlogTableWrapper(olapTable);
+ ChangeScanInfo changeScanInfo = buildChangeScanInfo(olapTable,
unboundRelation.getScanParams());
+ unboundRelation =
unboundRelation.withChangeScanInfo(changeScanInfo);
+ Preconditions.checkState(changeScanInfo != null);
+ scan = makeOlapTableStreamScan(wrapper, unboundRelation,
qualifier);
Review Comment:
因为可能查历史数据 需要历史版本 而这部分是确定分区后确定的
stream scan会在rewrite的时候拆开 具体确定对增量部分binlog和历史数据（原表）进行查询
然后这部分的schema是不一样的 也需要统一
同时stream也是一层view 在bindrelation这里对上层需要把schema统一
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
