Package 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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
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 classBaseParquetReaders<org.apache.flink.types.Row>
-
-