diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java index 7b7070c89f7b9a..d842ac31dd4f90 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java @@ -80,7 +80,7 @@ public enum PlanType { LOGICAL_WINDOW, // physical plans - // logical relations + // physical relations PHYSICAL_CTE_CONSUMER, PHYSICAL_EMPTY_RELATION, PHYSICAL_ES_SCAN, @@ -92,13 +92,13 @@ public enum PlanType { PHYSICAL_SCHEMA_SCAN, PHYSICAL_TVF_RELATION, - // logical sinks + // physical sinks PHYSICAL_FILE_SINK, PHYSICAL_OLAP_TABLE_SINK, PHYSICAL_HIVE_TABLE_SINK, PHYSICAL_RESULT_SINK, - // logical others + // physical others PHYSICAL_HASH_AGGREGATE, PHYSICAL_ASSERT_NUM_ROWS, PHYSICAL_CTE_PRODUCER, diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java index a75949740da14f..f8bc8f2db47924 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java @@ -30,7 +30,6 @@ import org.apache.doris.qe.ConnectContext; import org.apache.doris.qe.StmtExecutor; import org.apache.doris.transaction.TransactionState; -import org.apache.doris.transaction.TransactionStatus; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java index 0ed96f8b5c5af8..9d31a39b3e363a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java @@ -39,7 +39,7 @@ import java.util.Optional; /** - * logical olap table sink for insert command + * logical hive table sink for insert command */ public class LogicalHiveTableSink extends LogicalSink implements Sink, PropagateFuncDeps { diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java index 12abd0f8808da8..eee55e3c281ec5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java @@ -38,7 +38,7 @@ import java.util.Objects; import java.util.Optional; -/** abstract physical sink */ +/** abstract physical hive sink */ public class PhysicalHiveTableSink extends PhysicalSink implements Sink { private final HMSExternalDatabase database;