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/12/07 13:37:47 UTC
[iotdb] 01/01: change read dispatch to sync
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 e5915b1642c43b86e6bea4611cb1b9bb32ecab87
Merge: 72020ef96b 7df7c57c69
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Dec 7 21:30:02 2022 +0800
change read dispatch to sync
.../iotdb/db/mpp/execution/driver/Driver.java | 22 +++++++++++++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 8 +++++
.../scheduler/FragmentInstanceDispatcherImpl.java | 38 +++++++++++++---------
.../iotdb/db/mpp/statistics/QueryStatistics.java | 12 +++++++
4 files changed, 64 insertions(+), 16 deletions(-)
diff --cc server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
index 7f6074d709,5dd624f677..8a75b37eeb
--- 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,15 -82,20 +82,27 @@@ public class QueryStatistics
public static final String DISTRIBUTION_PLANNER = "DistributionPlanner";
public static final String DISPATCHER = "Dispatcher";
+ public static final String WAIT_FOR_DISPATCH = "WaitForDispatch";
+
+ public static final String DISPATCH_READ = "DispatchRead";
+
+ public static final String DRIVER_CLOSE = "CloseDriver";
+
+ public static final String DRIVER_INTERNAL_PROCESS = "DriverInternalProcess";
+
+ public static final String SEND_TSBLOCK = "SendTsBlock";
+
+ public static final String SET_NO_MORE_TSBLOCK = "SetNoMoreTsBlock";
+
public static final String SERVER_RPC_RT = "ServerRpcRT";
+ public static final String LOAD_TIME_SERIES_METADATA_ALIGNED = "loadTimeSeriesMetadata-aligned";
+ public static final String LOAD_TIME_SERIES_METADATA = "loadTimeSeriesMetadata";
+ public static final String LOAD_CHUNK_METADATA_LIST = "loadChunkMetadataList";
+ public static final String LOAD_PAGE_READER_LIST = "loadPageReaderList";
+ public static final String TIME_SERIES_METADATA_CACHE_MISS = "TimeSeriesMetadataCacheMiss";
+ public static final String CHUNK_CACHE_MISS = "ChunkCacheMiss";
+
private QueryStatistics() {
ScheduledExecutorService scheduledExecutor =
IoTDBThreadPoolFactory.newScheduledThreadPool(1, "Query-Statistics-Print");