This is an automated email from the ASF dual-hosted git repository.

marklau99 pushed a commit to branch rel/0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.13 by this push:
     new 1cc635cb27 rename methods (#7397)
1cc635cb27 is described below

commit 1cc635cb2703d8a774bd1592dc8367dfbdb316c8
Author: 周沛辰 <[email protected]>
AuthorDate: Thu Sep 22 15:16:40 2022 +0800

    rename methods (#7397)
---
 .../java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java  | 5 +++--
 .../db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java  | 4 ++--
 .../main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java | 4 ++--
 3 files changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java
index 389620123d..d8b081c649 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java
@@ -128,7 +128,7 @@ public class CompactionUtils {
       QueryContext queryContext,
       QueryDataSource queryDataSource)
       throws IOException, MetadataException {
-    Map<String, MeasurementSchema> schemaMap = 
deviceIterator.getAllMeasurementSchemas();
+    Map<String, MeasurementSchema> schemaMap = 
deviceIterator.getAllSchemasOfCurrentDevice();
 
     List<IMeasurementSchema> measurementSchemas = new 
ArrayList<>(schemaMap.values());
     if (measurementSchemas.isEmpty()) {
@@ -165,7 +165,8 @@ public class CompactionUtils {
       QueryContext queryContext,
       QueryDataSource queryDataSource)
       throws IOException, InterruptedException {
-    Map<String, MeasurementSchema> measurementSchemaMap = 
deviceIterator.getAllMeasurementSchemas();
+    Map<String, MeasurementSchema> measurementSchemaMap =
+        deviceIterator.getAllSchemasOfCurrentDevice();
     int subTaskNums = Math.min(measurementSchemaMap.size(), subTaskNum);
 
     // assign all measurements to different sub tasks
diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
index 6b33ad5ce0..6e2223d3c5 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
@@ -139,7 +139,7 @@ public class MultiTsFileDeviceIterator implements 
AutoCloseable {
    * files from the newest to the oldest in turn and start traversing the 
index tree from the
    * firstMeasurementNode node to get all the measurements under the current 
device.
    */
-  public Map<String, MeasurementSchema> getAllMeasurementSchemas() throws 
IOException {
+  public Map<String, MeasurementSchema> getAllSchemasOfCurrentDevice() throws 
IOException {
     Map<String, MeasurementSchema> schemaMap = new ConcurrentHashMap<>();
     // get schemas from the newest file to the oldest file
     for (TsFileResource resource : tsFileResources) {
@@ -150,7 +150,7 @@ public class MultiTsFileDeviceIterator implements 
AutoCloseable {
       List<TimeseriesMetadata> timeseriesMetadataList = new ArrayList<>();
       reader.getDeviceTimeseriesMetadata(
           timeseriesMetadataList,
-          deviceIteratorMap.get(resource).getMeasurementNode(),
+          
deviceIteratorMap.get(resource).getFirstMeasurementNodeOfCurrentDevice(),
           schemaMap.keySet(),
           true);
       for (TimeseriesMetadata timeseriesMetadata : timeseriesMetadataList) {
diff --git 
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java 
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java
index 3df4144fd0..95d72b7517 100644
--- 
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java
+++ 
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java
@@ -57,7 +57,7 @@ public class TsFileDeviceIterator implements 
Iterator<Pair<String, Boolean>> {
     }
     Pair<String, Pair<Long, Long>> startEndPair = queue.remove();
     try {
-      // first measurement node of this device
+      // get the first measurment node of this device, to know if the device 
is alignd
       MetadataIndexNode measurementNode =
           MetadataIndexNode.deserializeFrom(
               reader.readData(startEndPair.right.left, 
startEndPair.right.right));
@@ -71,7 +71,7 @@ public class TsFileDeviceIterator implements 
Iterator<Pair<String, Boolean>> {
     }
   }
 
-  public MetadataIndexNode getMeasurementNode() {
+  public MetadataIndexNode getFirstMeasurementNodeOfCurrentDevice() {
     return measurementNode;
   }
 }

Reply via email to