fix bug

apache · Feb 28, 2020 · 40893c4 · 40893c4
1 parent 3fb340e
commit 40893c4
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java
@@ -20,13 +20,14 @@
 
 import org.apache.iotdb.tsfile.read.TimeValuePair;
 import org.apache.iotdb.tsfile.read.common.BatchData;
-
 import java.io.IOException;
 
 public class BatchDataIterator implements IPointReader {
 
   private BatchData batchData;
 
+  private TimeValuePair currentTimeValue;
+
   public BatchDataIterator(BatchData batchData) {
     this.batchData = batchData;
   }
@@ -39,13 +40,14 @@ public boolean hasNextTimeValuePair() {
   @Override
   public TimeValuePair nextTimeValuePair() {
     TimeValuePair timeValuePair = new TimeValuePair(batchData.currentTime(), batchData.currentTsPrimitiveType());
+    currentTimeValue = timeValuePair;
     batchData.next();
     return timeValuePair;
   }
 
   @Override
   public TimeValuePair currentTimeValuePair() {
-    return new TimeValuePair(batchData.currentTime(), batchData.currentTsPrimitiveType());
+    return currentTimeValue;
   }
 
   @Override