You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by th...@apache.org on 2023/12/06 20:44:29 UTC

(flink) branch master updated (43fec308b32 -> 978bff3bb90)

This is an automated email from the ASF dual-hosted git repository.

thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 43fec308b32 [FLINK-33599] Run restore tests with RocksDB state backend (#23883)
     add 978bff3bb90 [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp (#18304)

No new revisions were added by this update.

Summary of changes:
 .../docs/connectors/table/formats/parquet.md       |  14 ++
 .../docs/connectors/table/formats/parquet.md       |  14 ++
 .../formats/parquet/ParquetFileFormatFactory.java  |  15 ++
 .../parquet/ParquetVectorizedInputFormat.java      |  13 +-
 .../formats/parquet/row/ParquetRowDataBuilder.java |  13 +-
 .../formats/parquet/row/ParquetRowDataWriter.java  |  67 ++++-
 .../parquet/utils/ParquetSchemaConverter.java      |  50 +++-
 .../formats/parquet/vector/ParquetDictionary.java  |  20 +-
 .../parquet/vector/ParquetSplitReaderUtil.java     |   3 +-
 .../vector/reader/AbstractColumnReader.java        |   2 +-
 .../vector/reader/TimestampColumnReader.java       | 101 +++++++-
 .../formats/parquet/ParquetTimestampITCase.java    | 280 +++++++++++++++++++++
 .../parquet/row/ParquetRowDataWriterTest.java      |  14 ++
 .../vector/ParquetInt64TimestampReaderTest.java    |  69 +++++
 .../runtime/stream/FsStreamingSinkITCaseBase.scala |  65 +++--
 15 files changed, 683 insertions(+), 57 deletions(-)
 create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
 create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/vector/ParquetInt64TimestampReaderTest.java