Package | Description |
---|---|
org.apache.arrow.consumers | |
org.apache.arrow.consumers.logical |
Modifier and Type | Class and Description |
---|---|
class |
AvroArraysConsumer
Consumer which consume array type values from avro decoder.
|
class |
AvroBooleanConsumer
Consumer which consume boolean type values from avro decoder.
|
class |
AvroBytesConsumer
Consumer which consume bytes type values from avro decoder.
|
class |
AvroDoubleConsumer
Consumer which consume double type values from avro decoder.
|
class |
AvroEnumConsumer
Consumer which consume enum type values from avro decoder.
|
class |
AvroFixedConsumer
Consumer which consume fixed type values from avro decoder.
|
class |
AvroFloatConsumer
Consumer which consume float type values from avro decoder.
|
class |
AvroIntConsumer
Consumer which consume int type values from avro decoder.
|
class |
AvroLongConsumer
Consumer which consume long type values from avro decoder.
|
class |
AvroMapConsumer
Consumer which consume map type values from avro decoder.
|
class |
AvroNullConsumer
Consumer which consume null type values from avro decoder.
|
class |
AvroStringConsumer
Consumer which consume string type values from avro decoder.
|
class |
AvroStructConsumer
Consumer which consume nested record type values from avro decoder.
|
class |
AvroUnionsConsumer
Consumer which consume unions type values from avro decoder.
|
class |
BaseAvroConsumer<T extends FieldVector>
Base class for non-skippable avro consumers.
|
class |
SkipConsumer
Consumer which skip (throw away) data from the decoder.
|
Modifier and Type | Method and Description |
---|---|
List<Consumer> |
CompositeAvroConsumer.getConsumers() |
Constructor and Description |
---|
AvroArraysConsumer(ListVector vector,
Consumer delegate)
Instantiate a ArrayConsumer.
|
AvroMapConsumer(MapVector vector,
Consumer delegate)
Instantiate a AvroMapConsumer.
|
AvroStructConsumer(StructVector vector,
Consumer[] delegates)
Instantiate a AvroStructConsumer.
|
AvroUnionsConsumer(UnionVector vector,
Consumer[] delegates,
Types.MinorType[] types)
Instantiate an AvroUnionConsumer.
|
Constructor and Description |
---|
CompositeAvroConsumer(List<Consumer> consumers) |
Modifier and Type | Class and Description |
---|---|
class |
AvroDateConsumer
Consumer which consume date type values from avro decoder.
|
class |
AvroDecimalConsumer
Consumer which consume decimal type values from avro decoder.
|
static class |
AvroDecimalConsumer.BytesDecimalConsumer
Consumer for decimal logical type with original bytes type.
|
static class |
AvroDecimalConsumer.FixedDecimalConsumer
Consumer for decimal logical type with original fixed type.
|
class |
AvroTimeMicroConsumer
Consumer which consume date time-micro values from avro decoder.
|
class |
AvroTimeMillisConsumer
Consumer which consume date time-millis values from avro decoder.
|
class |
AvroTimestampMicrosConsumer
Consumer which consume date timestamp-micro values from avro decoder.
|
class |
AvroTimestampMillisConsumer
Consumer which consume date timestamp-millis values from avro decoder.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.