Class AvroDecimalConsumer.FixedDecimalConsumer

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

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

    • FixedDecimalConsumer

      public FixedDecimalConsumer(DecimalVector vector, int size)
      Instantiate a FixedDecimalConsumer.
  • 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