Skip to content

Commit 741ff71

Browse files
committed
ARROW-400: set struct length on json load
1 parent c8eb49e commit 741ff71

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

java/vector/src/main/java/org/apache/arrow/vector/complex/MapVector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public class MapVector extends AbstractMapVector {
5050
private final SingleMapReaderImpl reader = new SingleMapReaderImpl(this);
5151
private final Accessor accessor = new Accessor();
5252
private final Mutator mutator = new Mutator();
53-
int valueCount;
53+
public int valueCount;
5454

5555
public MapVector(String name, BufferAllocator allocator, CallBack callBack) {
5656
super(name, allocator, callBack);

java/vector/src/main/java/org/apache/arrow/vector/file/json/JsonFileReader.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
import org.apache.arrow.vector.ValueVector.Mutator;
4848
import org.apache.arrow.vector.VarCharVector;
4949
import org.apache.arrow.vector.VectorSchemaRoot;
50+
import org.apache.arrow.vector.complex.NullableMapVector;
5051
import org.apache.arrow.vector.schema.ArrowVectorType;
5152
import org.apache.arrow.vector.types.pojo.Field;
5253
import org.apache.arrow.vector.types.pojo.Schema;
@@ -153,6 +154,9 @@ private void readVector(Field field, FieldVector vector) throws JsonParseExcepti
153154
}
154155
readToken(END_ARRAY);
155156
}
157+
if (vector instanceof NullableMapVector) {
158+
((NullableMapVector)vector).valueCount = count;
159+
}
156160
}
157161
readToken(END_OBJECT);
158162
}

0 commit comments

Comments
 (0)