org.apache.iceberg.flink.data

Class FlinkParquetReaders

java.lang.Object

org.apache.iceberg.data.parquet.BaseParquetReaders<org.apache.flink.types.Row>

org.apache.iceberg.flink.data.FlinkParquetReaders

public class FlinkParquetReaders
extends BaseParquetReaders<org.apache.flink.types.Row>

Method Summary

Modifier and Type	Method and Description
static ParquetValueReader<org.apache.flink.types.Row>	buildReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)
protected ParquetValueReader<org.apache.flink.types.Row>	createStructReader(java.util.List<org.apache.parquet.schema.Type> types, java.util.List<ParquetValueReader<?>> fieldReaders, Types.StructType structType)

Methods inherited from class org.apache.iceberg.data.parquet.BaseParquetReaders

createReader, createReader

Methods inherited from class java.lang.Object

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

Method Detail

buildReader

public static ParquetValueReader<org.apache.flink.types.Row> buildReader(Schema expectedSchema,
                                                                         org.apache.parquet.schema.MessageType fileSchema)

createStructReader

protected ParquetValueReader<org.apache.flink.types.Row> createStructReader(java.util.List<org.apache.parquet.schema.Type> types,
                                                                            java.util.List<ParquetValueReader<?>> fieldReaders,
                                                                            Types.StructType structType)

Specified by:

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