File tree Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -92,7 +92,10 @@ public void write(ExtendedDataOutput out) throws IOException{
92
92
if (this instanceof BasicSymbolVector )
93
93
flag += 128 ;
94
94
out .writeShort (flag );
95
- out .writeInt (rows ());
95
+ if (getDataType () == DATA_TYPE .DT_IOTANY )
96
+ out .writeInt (((BasicIotAnyVector ) this ).serializeAnyVectorRows ());
97
+ else
98
+ out .writeInt (rows ());
96
99
out .writeInt (columns ());
97
100
if (Entity .DATA_TYPE .valueOf (dataType ) == DATA_TYPE .DT_DECIMAL32_ARRAY
98
101
|| Entity .DATA_TYPE .valueOf (dataType ) == DATA_TYPE .DT_DECIMAL64_ARRAY
Original file line number Diff line number Diff line change @@ -122,6 +122,10 @@ public int rows() {
122
122
return indexs .rows ();
123
123
}
124
124
125
+ protected int serializeAnyVectorRows () {
126
+ return subVector .size () + 1 ;
127
+ }
128
+
125
129
@ JsonIgnore
126
130
@ Override
127
131
public int getUnitLength (){
You can’t perform that action at this time.
0 commit comments