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

[chore](mtmv)add plan log for UpdateMvByPartitionCommand (#40072) (#40413)

Browse Source 
pick: https://github.com/apache/doris/pull/40072
This commit is contained in:
zhangdong
2024-09-09 11:09:58 +08:00
committed by GitHub
parent 93a2518d12
commit e1e09badfa
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/UpdateMvByPartitionCommand.java
View File

@ -65,6 +65,8 @@ import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Lists;
import com.google.common.collect.Range;
import com.google.common.collect.Sets;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.ArrayList;
import java.util.HashSet;
@ -79,6 +81,8 @@ import java.util.stream.Collectors;
* Update mv by partition
*/
public class UpdateMvByPartitionCommand extends InsertOverwriteTableCommand {
private static final Logger LOG = LogManager.getLogger(UpdateMvByPartitionCommand.class);
private UpdateMvByPartitionCommand(LogicalPlan logicalQuery) {
super(logicalQuery, Optional.empty(), Optional.empty());
}
@ -104,6 +108,10 @@ public class UpdateMvByPartitionCommand extends InsertOverwriteTableCommand {
}
LogicalSink<? extends Plan> sink = UnboundTableSinkCreator.createUnboundTableSink(mv.getFullQualifiers(),
ImmutableList.of(), ImmutableList.of(), parts, plan);
if (LOG.isDebugEnabled()) {
LOG.debug("MTMVTask plan for mvName: {}, partitionNames: {}, plan: {}", mv.getName(), partitionNames,
sink.treeString());
}
return new UpdateMvByPartitionCommand(sink);
}