Skip to content

I
Iotdb

apache / Iotdb
10 个月 前同步成功

通知 25
Star 3344
Fork 916
I
Iotdb

体验新版 GitCode，发现更多精彩内容 >>

提交 906dc900 编写于 作者: S SilverNarcissus 提交者： Jialin Qiao
浏览文件
操作

fix bug in IOTDB-207 (#385)

上级 a371acb0
隐藏空白更改
内联 并排
Showing with 14 addition and 14 deletion
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
浏览文件 @ 906dc900
......@@ -199,8 +199,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, int[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -211,8 +211,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, long[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -223,8 +223,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, boolean[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -235,8 +235,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, float[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -247,8 +247,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, double[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -259,8 +259,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, BigDecimal[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......@@ -271,8 +271,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, Binary[] values, int batchSize) {
this.time = timestamps[timestamps.length - 1];
valueCountInOnePage += timestamps.length;
this.time = timestamps[batchSize - 1];
valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或