public class AvroTimestampMillisConsumer extends BaseAvroConsumer<TimeStampMilliVector>
TimeStampMilliVector
.currentIndex, vector
Constructor and Description |
---|
AvroTimestampMillisConsumer(TimeStampMilliVector vector)
Instantiate a AvroTimestampMillisConsumer.
|
Modifier and Type | Method and Description |
---|---|
void |
consume(org.apache.avro.io.Decoder decoder)
Consume a specific type value from avro decoder and write it to vector.
|
addNull, close, getVector, resetValueVector, setPosition
public AvroTimestampMillisConsumer(TimeStampMilliVector vector)
public void consume(org.apache.avro.io.Decoder decoder) throws IOException
Consumer
decoder
- avro decoder to read dataIOException
- on errorCopyright © 2023 The Apache Software Foundation. All rights reserved.