You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/11/13 03:47:54 UTC
[iotdb] 03/03: add server rt
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch QueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 16d0c84fcc6fccdbaece3e6957812b6b40f45de4
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Sun Nov 13 11:47:44 2022 +0800
add server rt
---
.../java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java | 2 ++
.../iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java | 9 ++++++++-
2 files changed, 10 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java b/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
index 597d1bbee9..9b0dd7e985 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
@@ -82,6 +82,8 @@ public class QueryStatistics {
public static final String DISTRIBUTION_PLANNER = "DistributionPlanner";
public static final String DISPATCHER = "Dispatcher";
+ public static final String SERVER_RPC_RT = "ServerRpcRT";
+
private QueryStatistics() {
ScheduledExecutorService scheduledExecutor =
IoTDBThreadPoolFactory.newScheduledThreadPool(1, "Query-Statistics-Print");
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
index 5110d4ff46..0307206da1 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
@@ -128,6 +128,7 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
+import static org.apache.iotdb.db.mpp.statistics.QueryStatistics.SERVER_RPC_RT;
import static org.apache.iotdb.db.service.basic.ServiceProvider.AUDIT_LOGGER;
import static org.apache.iotdb.db.service.basic.ServiceProvider.CURRENT_RPC_VERSION;
import static org.apache.iotdb.db.service.basic.ServiceProvider.QUERY_FREQUENCY_RECORDER;
@@ -384,7 +385,12 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
@Override
public TSExecuteStatementResp executeQueryStatementV2(TSExecuteStatementReq req) {
- return executeStatementV2(req);
+ long startTime = System.nanoTime();
+ try {
+ return executeStatementV2(req);
+ } finally {
+ QueryStatistics.getInstance().addCost(SERVER_RPC_RT, System.nanoTime() - startTime);
+ }
}
@Override
@@ -445,6 +451,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
if (finished) {
COORDINATOR.cleanupQueryExecution(req.queryId);
}
+ QueryStatistics.getInstance().addCost(SERVER_RPC_RT, System.nanoTime() - startTime);
}
}