Skip to content

Commit 9e9b9c2

Browse files
author
chengyitian
committed
AJ-781: modify serialize、deserialize logic for iotAnyVector;
1 parent 557da60 commit 9e9b9c2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/com/xxdb/data/BasicIotAnyVector.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ protected BasicIotAnyVector(ExtendedDataInput in) throws IOException {
3333
super(DATA_FORM.DF_VECTOR);
3434
int rows = in.readInt();
3535
int cols = in.readInt(); // 1
36-
long size = in.readLong();
36+
long size = in.readInt();
3737

3838
indexsDataType = new BasicIntVector(0);
3939
indexs = new BasicIntVector(0);
@@ -155,8 +155,8 @@ public int serialize(int indexStart, int offect, int targetNumElement, AbstractV
155155

156156
@Override
157157
protected void writeVectorToOutputStream(ExtendedDataOutput out) throws IOException {
158-
long size = indexs.rows();
159-
out.writeLong(size);
158+
int size = indexs.rows();
159+
out.writeInt(size);
160160

161161
for (int i = 0; i < size; i++) {
162162
out.writeInt(indexsDataType.getInt(i));

0 commit comments

Comments
 (0)