Class AvroDecimalConsumer.BytesDecimalConsumer

All Implemented Interfaces:
AutoCloseable, Consumer<DecimalVector>
Enclosing class:

public static class AvroDecimalConsumer.BytesDecimalConsumer extends AvroDecimalConsumer
Consumer for decimal logical type with original bytes type.
  • Constructor Details

    • BytesDecimalConsumer

      public BytesDecimalConsumer(DecimalVector vector)
      Instantiate a BytesDecimalConsumer.
  • Method Details

    • consume

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