You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/05/30 09:31:08 UTC
[iotdb] branch improvedAlign_for_expr updated: change path spliter
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch improvedAlign_for_expr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/improvedAlign_for_expr by this push:
new 6082a90753 change path spliter
6082a90753 is described below
commit 6082a907536a4355f28dfd1e0487660bb788f78f
Author: jt2594838 <jt...@163.com>
AuthorDate: Mon May 30 17:30:59 2022 +0800
change path spliter
---
.../org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java | 2 +-
.../main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java
index 30033ef65d..4ed70a64b0 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java
@@ -35,7 +35,7 @@ public class PathNodesGenerator {
public static String[] splitPathToNodes(String path) throws PathParseException {
try {
- return invokeParser(path);
+ return path.split("\\.");
} catch (ParseCancellationException e) {
throw new PathParseException(path);
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java
index 1bb1d9bf1d..1d1cd8369f 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java
@@ -68,6 +68,7 @@ public class TimePageWriter {
public void write(long time) {
timeEncoder.encode(time, timeOut);
statistics.update(time);
+ timeRawSize.addAndGet(Long.BYTES);
}
/** write time series into encoder */