java.lang.Object
org.apache.arrow.adapter.avro.consumers.BaseAvroConsumer<FixedSizeBinaryVector>
org.apache.arrow.adapter.avro.consumers.AvroFixedConsumer
All Implemented Interfaces:
AutoCloseable, Consumer<FixedSizeBinaryVector>

public class AvroFixedConsumer extends BaseAvroConsumer<FixedSizeBinaryVector>
Consumer which consume fixed type values from avro decoder. Write the data to FixedSizeBinaryVector.
  • Constructor Details

    • AvroFixedConsumer

      public AvroFixedConsumer(FixedSizeBinaryVector vector, int size)
      Instantiate a AvroFixedConsumer.
  • Method Details

    • consume

      public void consume(org.apache.avro.io.Decoder decoder) throws IOException
      Description copied from interface: Consumer
      Consume a specific type value from avro decoder and write it to vector.
      Parameters:
      decoder - avro decoder to read data
      Throws:
      IOException - on error