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 2019/06/28 02:34:51 UTC
[incubator-iotdb] branch feature_async_close_tsfile updated: add
reset in TVList
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
new 9116d78 add reset in TVList
9116d78 is described below
commit 9116d78cede5488d0c4d602d13e4198b630f004b
Author: 江天 <jt...@163.com>
AuthorDate: Fri Jun 28 10:32:41 2019 +0800
add reset in TVList
---
.../org/apache/iotdb/db/utils/datastructure/DoubleTVList.java | 1 +
.../java/org/apache/iotdb/db/utils/datastructure/LongTVList.java | 8 +++-----
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/DoubleTVList.java b/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/DoubleTVList.java
index f7d08ff..d8ae8ec 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/DoubleTVList.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/DoubleTVList.java
@@ -86,6 +86,7 @@ public class DoubleTVList extends TVList {
}
cloneList.size = size;
cloneList.sorted = sorted;
+ cloneList.limit = limit;
return cloneList;
}
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/LongTVList.java b/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/LongTVList.java
index f91ae23..e278d06 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/LongTVList.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/LongTVList.java
@@ -36,10 +36,7 @@ public class LongTVList extends TVList {
@Override
public void putLong(long timestamp, long value) {
- if ((size % SINGLE_ARRAY_SIZE) == 0) {
- values.add(new long[SINGLE_ARRAY_SIZE]);
- timestamps.add(new long[SINGLE_ARRAY_SIZE]);
- }
+ checkExpansion();
int arrayIndex = size / SINGLE_ARRAY_SIZE;
int elementIndex = size % SINGLE_ARRAY_SIZE;
timestamps.get(arrayIndex)[elementIndex] = timestamp;
@@ -89,6 +86,7 @@ public class LongTVList extends TVList {
}
cloneList.size = size;
cloneList.sorted = sorted;
+ cloneList.limit = limit;
return cloneList;
}
@@ -142,7 +140,7 @@ public class LongTVList extends TVList {
@Override
protected void expandValues() {
-
+ values.add(new long[SINGLE_ARRAY_SIZE]);
}
@Override