Override methods in composite producers

Author: martin-traverse

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

@@ -56,10 +56,28 @@ public void produce(Encoder encoder) throws IOException {
     currentIndex++;
   }
 
+  @Override
+  public void skipNull() {
+    delegate.skipNull();
+    super.skipNull();
+  }
+
+  @Override
+  public void setPosition(int index) {
+    delegate.setPosition(index);
+    super.setPosition(index);
+  }
+
   @Override
   @SuppressWarnings("unchecked")
   public boolean resetValueVector(ListVector vector) {
     ((Producer<FieldVector>) delegate).resetValueVector(vector.getDataVector());
     return super.resetValueVector(vector);
   }
+
+  @Override
+  public void close() throws Exception {
+    delegate.close();
+    super.close();
+  }
 }

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

@@ -55,10 +55,28 @@ public void produce(Encoder encoder) throws IOException {
     currentIndex++;
   }
 
+  @Override
+  public void skipNull() {
+    delegate.skipNull();
+    super.skipNull();
+  }
+
+  @Override
+  public void setPosition(int index) {
+    delegate.setPosition(index);
+    super.setPosition(index);
+  }
+
   @Override
   @SuppressWarnings("unchecked")
   public boolean resetValueVector(MapVector vector) {
     ((Producer<FieldVector>) delegate).resetValueVector(vector.getDataVector());
     return super.resetValueVector(vector);
   }
+
+  @Override
+  public void close() throws Exception {
+    delegate.close();
+    super.close();
+  }
 }

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

@@ -47,8 +47,15 @@ public void produce(Encoder encoder) throws IOException {
   }
 
   @Override
-  public void close() throws Exception {
-    delegate.close();
+  public void skipNull() {
+    delegate.skipNull();
+    super.skipNull();
+  }
+
+  @Override
+  public void setPosition(int index) {
+    delegate.setPosition(index);
+    super.setPosition(index);
   }
 
   @Override
@@ -60,4 +67,9 @@ public boolean resetValueVector(T vector) {
   public T getVector() {
     return delegate.getVector();
   }
+
+  @Override
+  public void close() throws Exception {
+    delegate.close();
+  }
 }

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

@@ -40,22 +40,44 @@ public AvroStructProducer(StructVector vector, Producer<? extends FieldVector>[]
   @Override
   public void produce(Encoder encoder) throws IOException {
 
-    for (Producer<? extends FieldVector> delegate : delegates) {
+    for (Producer<?> delegate : delegates) {
       delegate.produce(encoder);
     }
 
     currentIndex++;
   }
 
+  @Override
+  public void skipNull() {
+    for (Producer<?> delegate : delegates) {
+      delegate.skipNull();
+    }
+    super.skipNull();
+  }
+
+  @Override
+  public void setPosition(int index) {
+    for (Producer<?> delegate : delegates) {
+      delegate.setPosition(index);
+    }
+    super.setPosition(index);
+  }
+
   @Override
   @SuppressWarnings("unchecked")
   public boolean resetValueVector(StructVector vector) {
-
     for (int i = 0; i < delegates.length; i++) {
       Producer<FieldVector> delegate = (Producer<FieldVector>) delegates[i];
       delegate.resetValueVector(vector.getChildrenFromFields().get(i));
     }
-
     return super.resetValueVector(vector);
   }
+
+  @Override
+  public void close() throws Exception {
+    for (Producer<?> delegate : delegates) {
+      delegate.close();
+    }
+    super.close();
+  }
 }