database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: proper planning of shadow columns for load and schema change concurrent execution (#49332) (#50710)

Browse Source
This commit is contained in:
hui lai
2025-05-09 11:15:08 +08:00
committed by GitHub
parent f0f0f21e5f
commit 0347e8a3c6
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java
View File

@ -292,11 +292,15 @@ public class BindSink implements AnalysisRuleFactory {
Map<Expression, Expression> replaceMap = Maps.newHashMap();
NereidsParser expressionParser = new NereidsParser();
List<Column> materializedViewColumn = Lists.newArrayList();
List<Column> shadowColumns = Lists.newArrayList();
// generate slots not mentioned in sql, mv slots and shaded slots.
for (Column column : boundSink.getTargetTable().getFullSchema()) {
if (column.isMaterializedViewColumn()) {
materializedViewColumn.add(column);
continue;
} else if (Column.isShadowColumn(column.getName())) {
shadowColumns.add(column);
continue;
}
if (columnToChildOutput.containsKey(column)
// do not process explicitly use DEFAULT value here:
@ -423,6 +427,15 @@ public class BindSink implements AnalysisRuleFactory {
columnToOutput.put(column.getName(), output);
}
}
for (Column column : shadowColumns) {
NamedExpression expression = columnToOutput.get(column.getNonShadowName());
if (expression != null) {
Alias alias = (Alias) expression;
Expression newExpr = TypeCoercionUtils.castIfNotSameType(alias.child(),
DataType.fromCatalogType(column.getType()));
columnToOutput.put(column.getName(), new Alias(newExpr, column.getName()));
}
}
return columnToOutput;
}