org.apache.iceberg.flink.data

Class FlinkAvroReader

java.lang.Object

org.apache.iceberg.data.avro.DataReader<org.apache.flink.types.Row>

org.apache.iceberg.flink.data.FlinkAvroReader

All Implemented Interfaces:

org.apache.avro.io.DatumReader<org.apache.flink.types.Row>

public class FlinkAvroReader
extends DataReader<org.apache.flink.types.Row>

Constructor Summary

Constructors

Constructor and Description
FlinkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema)

Method Summary

Modifier and Type	Method and Description
protected ValueReader<?>	createStructReader(Types.StructType struct, java.util.List<ValueReader<?>> fields, java.util.Map<java.lang.Integer,?> idToConstant)

Methods inherited from class org.apache.iceberg.data.avro.DataReader

create, create, read, setSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkAvroReader

public FlinkAvroReader(Schema expectedSchema,
                       org.apache.avro.Schema readSchema)

Method Detail

createStructReader

protected ValueReader<?> createStructReader(Types.StructType struct,
                                            java.util.List<ValueReader<?>> fields,
                                            java.util.Map<java.lang.Integer,?> idToConstant)

Overrides:

createStructReader in class DataReader<org.apache.flink.types.Row>