Add log info in dynamic one column data. (#156)

thulab · Jun 5, 2018 · 94ec2aa · 94ec2aa
1 parent 396e211
commit 94ec2aa
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 99 deletions.
diff --git a/src/main/java/cn/edu/tsinghua/tsfile/timeseries/read/query/DynamicOneColumnData.java b/src/main/java/cn/edu/tsinghua/tsfile/timeseries/read/query/DynamicOneColumnData.java
@@ -339,10 +339,10 @@ public void putBinary(Binary v) {
      */
     private void rangeCheck(int idx) {
         if (idx < 0) {
-            throw new IndexOutOfBoundsException("Index is negative: " + idx);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData value range check, Index is negative: " + idx);
         }
         if (idx >= valueLength) {
-            throw new IndexOutOfBoundsException("Index : " + idx + ". Length : " + valueLength);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData value range check, Index : " + idx + ". Length : " + valueLength);
         }
     }
 
@@ -352,19 +352,19 @@ private void rangeCheck(int idx) {
      */
     private void rangeCheckForTime(int idx) {
         if (idx < 0) {
-            throw new IndexOutOfBoundsException("Index is negative: " + idx);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData time range check, Index is negative: " + idx);
         }
         if (idx >= timeLength) {
-            throw new IndexOutOfBoundsException("Index : " + idx + ". Length : " + valueLength);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData time range check, Index : " + idx + ". Length : " + timeLength);
         }
     }
 
     private void rangeCheckForEmptyTime(int idx) {
         if (idx < 0) {
-            throw new IndexOutOfBoundsException("Index is negative: " + idx);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData empty time range check, Index is negative: " + idx);
         }
         if (idx >= emptyTimeLength) {
-            throw new IndexOutOfBoundsException("Index : " + idx + ". Length : " + valueLength);
+            throw new IndexOutOfBoundsException("DynamicOneColumnData empty time range check, Index : " + idx + ". Length : " + emptyTimeLength);
         }
     }
 

diff --git a/...u/tsinghua/tsfile/timeseries/readV2/query/impl/QueryExecutorWithGlobalTimeFilterImpl.java b/...u/tsinghua/tsfile/timeseries/readV2/query/impl/QueryExecutorWithGlobalTimeFilterImpl.java
diff --git a/...a/cn/edu/tsinghua/tsfile/timeseries/readV2/query/impl/QueryExecutorWithoutFilterImpl.java b/...a/cn/edu/tsinghua/tsfile/timeseries/readV2/query/impl/QueryExecutorWithoutFilterImpl.java
diff --git a/src/main/java/cn/edu/tsinghua/tsfile/timeseries/write/record/TSRecord.java b/src/main/java/cn/edu/tsinghua/tsfile/timeseries/write/record/TSRecord.java
@@ -21,6 +21,10 @@ public TSRecord(long timestamp, String deltaObjectId) {
         this.deltaObjectId = deltaObjectId;
     }
 
+    public void setTime(long timestamp) {
+        this.time = timestamp;
+    }
+
     public void addTuple(DataPoint tuple) {
         this.dataPointList.add(tuple);
     }