Interface | Description |
---|---|
ParentDataHolder |
Interface for
RowConverter for extracting nested value from parquet record. |
Class | Description |
---|---|
ParquetRecordReader<T> |
Customized
ParquetRecordReader that support start read from
particular position. |
ParquetSchemaConverter |
Schema converter converts Parquet schema to and from Flink internal types.
|
ParquetTimestampUtils |
Utility class for decoding INT96 encoded parquet timestamp to timestamp millis in GMT.
|
RowConverter |
Extends from
GroupConverter to convert an nested Parquet Record into Row. |
RowMaterializer |
Row materializer for
RowReadSupport . |
RowReadSupport |
A Parquet
ReadSupport implementation for reading Parquet record as Row . |
SerializableConfiguration |
Wrap
Configuration to a serializable class. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.