[chore](explain) add annotation in explain string whether nereids is ON #24394

This commit is contained in:
zclllyybb
2023-09-15 10:17:17 +08:00
committed by GitHub
parent 14163df429
commit e0834b2f46
2 changed files with 8 additions and 8 deletions

View File

@ -80,7 +80,7 @@ public class ExplainCommand extends Command implements NoForward {
planner.plan(logicalPlanAdapter, ctx.getSessionVariable().toThrift());
executor.setPlanner(planner);
executor.checkBlockRules();
executor.handleExplainStmt(planner.getExplainString(new ExplainOptions(level)));
executor.handleExplainStmt(planner.getExplainString(new ExplainOptions(level)), true);
}
@Override

View File

@ -1337,7 +1337,7 @@ public class StmtExecutor {
if (queryStmt.isExplain()) {
String explainString = planner.getExplainString(queryStmt.getExplainOptions());
handleExplainStmt(explainString);
handleExplainStmt(explainString, false);
return;
}
@ -1737,7 +1737,7 @@ public class StmtExecutor {
ExplainOptions explainOptions = insertStmt.getQueryStmt().getExplainOptions();
insertStmt.setIsExplain(explainOptions);
String explainString = planner.getExplainString(explainOptions);
handleExplainStmt(explainString);
handleExplainStmt(explainString, false);
return;
}
@ -2198,11 +2198,11 @@ public class StmtExecutor {
private void handleLockTablesStmt() {
}
public void handleExplainStmt(String result) throws IOException {
ShowResultSetMetaData metaData =
ShowResultSetMetaData.builder()
.addColumn(new Column("Explain String", ScalarType.createVarchar(20)))
.build();
public void handleExplainStmt(String result, boolean isNereids) throws IOException {
ShowResultSetMetaData metaData = ShowResultSetMetaData.builder()
.addColumn(new Column("Explain String" + (isNereids ? "(Nereids Planner)" : "(Old Planner)"),
ScalarType.createVarchar(20)))
.build();
sendMetaData(metaData);
// Send result set.