Skip to content

Commit d7e6665

Browse files
Fix delegate offset for map producer
1 parent 71bdb92 commit d7e6665

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroMapProducer.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -51,15 +51,12 @@ public void produce(Encoder encoder) throws IOException {
5151
currentIndex++;
5252
}
5353

54-
@Override
55-
public void skipNull() {
56-
delegate.skipNull();
57-
super.skipNull();
58-
}
54+
// Do not override skipNull(), delegate will not have an entry if the map is null
5955

6056
@Override
6157
public void setPosition(int index) {
62-
delegate.setPosition(index);
58+
int delegateOffset = vector.getOffsetBuffer().getInt(index * (long) Integer.BYTES);
59+
delegate.setPosition(delegateOffset);
6360
super.setPosition(index);
6461
}
6562

0 commit comments

Comments
 (0)