This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7dea735db98 [IOTDB-6266] Add the ability to flush syncIndex and update
reader periodically for IoTConsensus (#11737)
add 81af7f4c7e7 Add more query metrics in the fragment instance level
(#11719)
No new revisions were added by this update.
Summary of changes:
.../fragment/FragmentInstanceContext.java | 57 ++
.../fragment/FragmentInstanceManager.java | 15 +-
.../execution/fragment/QueryContext.java | 14 +-
.../execution/fragment/QueryStatistics.java | 69 ++
.../operator/source/AlignedSeriesScanUtil.java | 4 +-
.../execution/operator/source/FileLoaderUtils.java | 63 +-
.../execution/operator/source/SeriesScanUtil.java | 50 +-
.../metric/QueryExecutionMetricSet.java | 24 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 10 +-
.../metric/QueryRelatedResourceMetricSet.java | 144 +++-
.../metric/SeriesScanCostMetricSet.java | 825 ++++++++++++++-------
.../queryengine/plan/execution/QueryExecution.java | 1 +
.../schemaregion/utils/ResourceByPathUtils.java | 21 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../memtable/AlignedReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/IMemTable.java | 6 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/DiskChunkLoader.java | 21 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 11 +-
.../read/reader/chunk/MemChunkLoader.java | 11 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 2 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 17 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 4 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 13 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 25 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
33 files changed, 1050 insertions(+), 416 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryStatistics.java