shizy818 commented on code in PR #16353:
URL: https://github.com/apache/iotdb/pull/16353#discussion_r2646391758
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java:
##########
@@ -141,17 +140,37 @@ public FragmentInstanceStateMachine getStateMachine() {
return stateMachine;
}
+ // Check if this fragment instance should be ignored for statistics
+ // (i.e., it contains ExplainAnalyzeOperator only)
+ private boolean shouldIgnoreForStatistics() {
+ if (drivers == null || drivers.isEmpty()) {
+ return false;
+ }
+ // Check if any driver contains ExplainAnalyzeOperator
+ return drivers.stream()
+ .anyMatch(
+ driver ->
+ driver.getDriverContext().getOperatorContexts().stream()
+ .anyMatch(
+ operatorContext ->
+ ExplainAnalyzeOperator.class
+ .getSimpleName()
+ .equals(operatorContext.getOperatorType())));
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
