From a7660eb1e9695a47d56cd2bb573fbb74437c493d Mon Sep 17 00:00:00 2001 From: seawinde Date: Wed, 20 Dec 2023 13:08:21 +0800 Subject: [PATCH] remove unuse code --- .../nereids/trees/plans/commands/info/CreateMTMVInfo.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java index 032f677409ec6c..6d81191c8bed90 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java @@ -201,7 +201,7 @@ private void analyzeProperties() { public void analyzeQuery(ConnectContext ctx) { // create table as select NereidsPlanner planner = new NereidsPlanner(ctx.getStatementContext()); - // this is for column infer + // this is for expression column name infer when not use alias LogicalSink logicalSink = new UnboundResultSink<>(logicalQuery); Plan plan = planner.plan(logicalSink, PhysicalProperties.ANY, ExplainLevel.ALL_PLAN); if (plan.anyMatch(node -> node instanceof OneRowRelation)) { @@ -306,8 +306,6 @@ private void getColumns(Plan plan) { if (!CollectionUtils.isEmpty(simpleColumnDefinitions) && simpleColumnDefinitions.size() != slots.size()) { throw new AnalysisException("simpleColumnDefinitions size is not equal to the query's"); } - // slots = BindExpression.inferColumnNames(plan).stream() - // .map(NamedExpression::toSlot).collect(Collectors.toList()); Set colNames = Sets.newHashSet(); for (int i = 0; i < slots.size(); i++) { String colName = CollectionUtils.isEmpty(simpleColumnDefinitions) ? slots.get(i).getName()