This is an automated email from the ASF dual-hosted git repository.
colinlee pushed a commit to branch colin_support_read_tree
in repository https://gitbox.apache.org/repos/asf/tsfile.git
The following commit(s) were added to refs/heads/colin_support_read_tree by
this push:
new dac2010c tmp code.
dac2010c is described below
commit dac2010cee9780b68d48db8635e0d75801cdbc34
Author: ColinLee <[email protected]>
AuthorDate: Wed Nov 19 18:22:39 2025 +0800
tmp code.
---
.../tsfile/write/MetadataIndexConstructorTest.java | 132 ++++++++++-----------
1 file changed, 66 insertions(+), 66 deletions(-)
diff --git
a/java/tsfile/src/test/java/org/apache/tsfile/write/MetadataIndexConstructorTest.java
b/java/tsfile/src/test/java/org/apache/tsfile/write/MetadataIndexConstructorTest.java
index 79908270..43c1167b 100644
---
a/java/tsfile/src/test/java/org/apache/tsfile/write/MetadataIndexConstructorTest.java
+++
b/java/tsfile/src/test/java/org/apache/tsfile/write/MetadataIndexConstructorTest.java
@@ -21,7 +21,6 @@ package org.apache.tsfile.write;
import org.apache.tsfile.common.conf.TSFileConfig;
import org.apache.tsfile.common.conf.TSFileDescriptor;
import org.apache.tsfile.common.constant.TsFileConstant;
-import org.apache.tsfile.constant.TestConstant;
import org.apache.tsfile.enums.TSDataType;
import org.apache.tsfile.file.IMetadataIndexEntry;
import org.apache.tsfile.file.metadata.DeviceMetadataIndexEntry;
@@ -71,7 +70,7 @@ public class MetadataIndexConstructorTest {
private static final Logger logger =
LoggerFactory.getLogger(MetadataIndexConstructorTest.class);
private final TSFileConfig conf = TSFileDescriptor.getInstance().getConfig();
private static final String FILE_PATH =
-
TestConstant.BASE_OUTPUT_PATH.concat("MetadataIndexConstructorTest.tsfile");
+
"/Users/colin/dev/tsfile/cpp/cmake-build-debug/test/lib/tsfile_writer_tree_test_sojl1BbVpR.tsfile";
private static final String measurementPrefix = "sensor_";
private static final String vectorPrefix = "vector_";
@@ -87,9 +86,9 @@ public class MetadataIndexConstructorTest {
public void after() {
conf.setMaxDegreeOfIndexNode(maxDegreeOfIndexNode);
File file = new File(FILE_PATH);
- if (file.exists()) {
- file.delete();
- }
+// if (file.exists()) {
+// file.delete();
+// }
}
/** Example 1: 5 entities with 5 measurements each */
@@ -205,78 +204,79 @@ public class MetadataIndexConstructorTest {
*/
private void test(IDeviceID[] devices, int[][] vectorMeasurement, String[][]
singleMeasurement) {
// 1. generate file
- generateFile(devices, vectorMeasurement, singleMeasurement);
+// generateFile(devices, vectorMeasurement, singleMeasurement);
// 2. read metadata from file
- List<IDeviceID> actualDevices = new ArrayList<>(); // contains all device
by sequence
- List<List<String>> actualMeasurements =
- new ArrayList<>(); // contains all measurements group by device
- readMetaDataDFS(actualDevices, actualMeasurements);
- // 3. generate correct result
- List<IDeviceID> correctDevices = new ArrayList<>(); // contains all device
by sequence
- List<List<String>> correctFirstMeasurements =
- new ArrayList<>(); // contains first measurements of every leaf, group
by device
- List<String> correctPaths = new ArrayList<>(); // contains all paths by
sequence
- generateCorrectResult(
- correctDevices,
- correctFirstMeasurements,
- correctPaths,
- devices,
- vectorMeasurement,
- singleMeasurement);
- // 4. compare correct result with TsFile's metadata
- Arrays.sort(devices);
- // 4.1 make sure device in order
- assertEquals(correctDevices.size(), devices.length);
- assertEquals(actualDevices.size(), correctDevices.size());
- for (int i = 0; i < actualDevices.size(); i++) {
- assertEquals(actualDevices.get(i), correctDevices.get(i));
- }
+// List<IDeviceID> actualDevices = new ArrayList<>(); // contains all
device by sequence
+// List<List<String>> actualMeasurements =
+// new ArrayList<>(); // contains all measurements group by device
+// readMetaDataDFS(actualDevices, actualMeasurements);
+// // 3. generate correct result
+// List<IDeviceID> correctDevices = new ArrayList<>(); // contains all
device by sequence
+// List<List<String>> correctFirstMeasurements =
+// new ArrayList<>(); // contains first measurements of every leaf,
group by device
+// List<String> correctPaths = new ArrayList<>(); // contains all paths by
sequence
+// generateCorrectResult(
+// correctDevices,
+// correctFirstMeasurements,
+// correctPaths,
+// devices,
+// vectorMeasurement,
+// singleMeasurement);
+// // 4. compare correct result with TsFile's metadata
+// Arrays.sort(devices);
+// // 4.1 make sure device in order
+// assertEquals(correctDevices.size(), devices.length);
+// assertEquals(actualDevices.size(), correctDevices.size());
+// for (int i = 0; i < actualDevices.size(); i++) {
+// assertEquals(actualDevices.get(i), correctDevices.get(i));
+// }
// 4.2 make sure timeseries in order
try (TsFileSequenceReader reader = new TsFileSequenceReader(FILE_PATH)) {
- Iterator<Pair<IDeviceID, Boolean>> iterator =
reader.getAllDevicesIteratorWithIsAligned();
- while (iterator.hasNext()) {
- for (IDeviceID correctDevice : correctDevices) {
- assertEquals(correctDevice, iterator.next().left);
- }
- }
- assertFalse(iterator.hasNext());
+// Iterator<Pair<IDeviceID, Boolean>> iterator =
reader.getAllDevicesIteratorWithIsAligned();
+// while (iterator.hasNext()) {
+// for (IDeviceID correctDevice : correctDevices) {
+// assertEquals(correctDevice, iterator.next().left);
+// }
+// }
+// assertFalse(iterator.hasNext());
Map<IDeviceID, List<TimeseriesMetadata>> allTimeseriesMetadata =
reader.getAllTimeseriesMetadata(false);
- for (int j = 0; j < actualDevices.size(); j++) {
- for (int i = 0; i < actualMeasurements.get(j).size(); i++) {
- assertEquals(
-
allTimeseriesMetadata.get(actualDevices.get(j)).get(i).getMeasurementId(),
- correctFirstMeasurements.get(j).get(i));
- }
- }
+ System.out.println(allTimeseriesMetadata);
+// for (int j = 0; j < actualDevices.size(); j++) {
+// for (int i = 0; i < actualMeasurements.get(j).size(); i++) {
+// assertEquals(
+//
allTimeseriesMetadata.get(actualDevices.get(j)).get(i).getMeasurementId(),
+// correctFirstMeasurements.get(j).get(i));
+// }
+// }
} catch (IOException e) {
e.printStackTrace();
fail(e.getMessage());
}
- // 4.3 make sure split leaf correctly
- for (int j = 0; j < actualDevices.size(); j++) {
- for (int i = 0; i < actualMeasurements.get(j).size(); i++) {
- assertEquals(
- actualMeasurements.get(j).get(i),
- correctFirstMeasurements.get(j).get(i *
conf.getMaxDegreeOfIndexNode()));
- }
- }
- try (TsFileSequenceReader reader = new TsFileSequenceReader(FILE_PATH)) {
- Iterator<List<Path>> iterator = reader.getPathsIterator();
- int idx = 0;
- while (iterator.hasNext()) {
- for (Path actualPath : iterator.next()) {
- assertEquals(actualPath.getFullPath(), correctPaths.get(idx));
- idx++;
- }
- }
- assertEquals(correctPaths.size(), idx);
- } catch (IOException e) {
- e.printStackTrace();
- fail(e.getMessage());
- }
+// // 4.3 make sure split leaf correctly
+// for (int j = 0; j < actualDevices.size(); j++) {
+// for (int i = 0; i < actualMeasurements.get(j).size(); i++) {
+// assertEquals(
+// actualMeasurements.get(j).get(i),
+// correctFirstMeasurements.get(j).get(i *
conf.getMaxDegreeOfIndexNode()));
+// }
+// }
+// try (TsFileSequenceReader reader = new TsFileSequenceReader(FILE_PATH)) {
+// Iterator<List<Path>> iterator = reader.getPathsIterator();
+// int idx = 0;
+// while (iterator.hasNext()) {
+// for (Path actualPath : iterator.next()) {
+// assertEquals(actualPath.getFullPath(), correctPaths.get(idx));
+// idx++;
+// }
+// }
+// assertEquals(correctPaths.size(), idx);
+// } catch (IOException e) {
+// e.printStackTrace();
+// fail(e.getMessage());
+// }
}
/**
