Package org.apache.parquet.format.event

Class Consumers.DelegatingFieldConsumer

java.lang.Object

org.apache.parquet.format.event.Consumers.DelegatingFieldConsumer

All Implemented Interfaces:

FieldConsumer

Enclosing class:

Consumers

public static class Consumers.DelegatingFieldConsumer
extends Object
implements FieldConsumer

Delegates reading the field to TypedConsumers. There is one TypedConsumer per thrift type. use onField(TFieldIdEnum, TypedConsumer) et al. to consume specific thrift fields.

See Also:

• Consumers.fieldConsumer()

Method Summary

Modifier and Type	Method	Description
void	consumeField(org.apache.thrift.protocol.TProtocol protocol, EventBasedThriftReader reader, short id, byte type)	called by the EventBasedThriftReader when reading a field from a Struct
Consumers.DelegatingFieldConsumer	onField(org.apache.thrift.TFieldIdEnum e, TypedConsumer typedConsumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

onField

public Consumers.DelegatingFieldConsumer onField(org.apache.thrift.TFieldIdEnum e,
 TypedConsumer typedConsumer)

consumeField

public void consumeField(org.apache.thrift.protocol.TProtocol protocol,
 EventBasedThriftReader reader,
 short id,
 byte type)
                  throws org.apache.thrift.TException

Description copied from interface: FieldConsumer

called by the EventBasedThriftReader when reading a field from a Struct

Specified by:

consumeField in interface FieldConsumer

Parameters:

protocol - the underlying protocol

reader - the reader to delegate to further calls.

id - the id of the field

type - the type of the field

Throws:

org.apache.thrift.TException - if any thrift related error occurs during the reading