This is an automated email from the ASF dual-hosted git repository. xiangweiwei pushed a commit to branch clusterAlignbydevice in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 190bf39809241ef1f8768081bcd62433a198e44a Author: Alima777 <[email protected]> AuthorDate: Thu Oct 21 15:27:00 2021 +0800 use getAllMeasurementSchemaByPrefix interface --- .../java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java index 89c6df9..695923b 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java +++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java @@ -48,6 +48,7 @@ import org.apache.iotdb.tsfile.write.schema.VectorMeasurementSchema; import java.io.IOException; import java.util.ArrayList; +import java.util.Collection; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; @@ -234,8 +235,8 @@ public class AlignByDeviceDataSet extends QueryDataSet { try { Set<String> res = new HashSet<>(); // TODO: Implement this method in Cluster MManager - List<IMeasurementSchema> measurementSchemas = - IoTDB.metaManager.getAllMeasurementByDevicePath(device); + Collection<IMeasurementSchema> measurementSchemas = + IoTDB.metaManager.getAllMeasurementSchemaByPrefix(device).values(); for (IMeasurementSchema schema : measurementSchemas) { if (schema instanceof VectorMeasurementSchema) { for (String subMeasurement : schema.getSubMeasurementsList()) {
