This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch test_meta
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/test_meta by this push:
new 2fa8c0f seperate io and deserialize
2fa8c0f is described below
commit 2fa8c0f5de7442c21f4e4d5383209bcfe2684649
Author: qiaojialin <[email protected]>
AuthorDate: Wed Apr 15 14:52:23 2020 +0800
seperate io and deserialize
---
.../java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java
index 5240489..ab2d948 100644
---
a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java
+++
b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReader.java
@@ -301,13 +301,16 @@ public class TsFileSequenceReader implements
AutoCloseable {
Pair<Long, Integer> deviceMetadataIndex =
tsFileMetaData.getDeviceMetadataIndex().get(device);
Map<String, TimeseriesMetadata> deviceMetadata = new HashMap<>();
ByteBuffer buffer = readData(deviceMetadataIndex.left,
deviceMetadataIndex.right);
+ System.out.println("read TimeseriesMetadata io cost: " +
(System.currentTimeMillis() - start));
+ System.out.println("timeseriesMetadata size: " +
deviceMetadataIndex.right);
+ start = System.currentTimeMillis();
while (buffer.hasRemaining()) {
TimeseriesMetadata tsMetaData =
TimeseriesMetadata.deserializeFrom(buffer);
deviceMetadata.put(tsMetaData.getMeasurementId(), tsMetaData);
}
- System.out.println("read TimeseriesMetadata " + deviceMetadata.size());
- System.out.println(System.currentTimeMillis() - start);
+ System.out.println("read TimeseriesMetadata deserialize cost: " +
(System.currentTimeMillis() - start));
+ System.out.println("Timeseries Metadata size: " + deviceMetadata.size());
return deviceMetadata;
}