[flink] branch master updated (7399bb4 -> ce3631a)

[tw...@apache.org]

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

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


    from 7399bb4  [hotfix][tests] Remove try/catch from SavepointWindowReaderITCase.testApplyEvictorWindowStateReader
     add ce3631a  [FLINK-22622][parquet] Drop BatchTableSource ParquetTableSource and related classes

No new revisions were added by this update.

Summary of changes:
 flink-formats/flink-parquet/pom.xml                |  30 +-
 .../flink/formats/parquet/ParquetInputFormat.java  | 323 -----------
 .../formats/parquet/ParquetMapInputFormat.java     | 143 -----
 .../formats/parquet/ParquetPojoInputFormat.java    | 138 -----
 .../formats/parquet/ParquetRowInputFormat.java     |  49 --
 .../flink/formats/parquet/ParquetTableSource.java  | 616 ---------------------
 .../formats/parquet/utils/ParentDataHolder.java    |  25 -
 .../formats/parquet/utils/ParquetRecordReader.java | 311 -----------
 .../parquet/utils/ParquetSchemaConverter.java      | 510 -----------------
 .../parquet/utils/ParquetTimestampUtils.java       |  69 ---
 .../flink/formats/parquet/utils/RowConverter.java  | 541 ------------------
 .../formats/parquet/utils/RowMaterializer.java     |  49 --
 .../formats/parquet/utils/RowReadSupport.java      |  54 --
 .../formats/parquet/ParquetMapInputFormatTest.java | 125 -----
 .../parquet/ParquetPojoInputFormatTest.java        | 115 ----
 .../formats/parquet/ParquetRowInputFormatTest.java | 460 ---------------
 .../formats/parquet/ParquetTableSourceITCase.java  | 117 ----
 .../formats/parquet/ParquetTableSourceTest.java    | 252 ---------
 .../formats/parquet/pojo/PojoSimpleRecord.java     |  50 --
 .../parquet/utils/ParquetRecordReaderTest.java     | 380 -------------
 .../parquet/utils/ParquetSchemaConverterTest.java  | 189 -------
 .../flink/formats/parquet/utils/TestUtil.java      | 302 ----------
 .../src/test/resources/avro/nested.avsc            |  35 --
 .../src/test/resources/avro/simple.avsc            |  12 -
 24 files changed, 4 insertions(+), 4891 deletions(-)
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetMapInputFormat.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetPojoInputFormat.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetRowInputFormat.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParentDataHolder.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecordReader.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetTimestampUtils.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowMaterializer.java
 delete mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowReadSupport.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetMapInputFormatTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetPojoInputFormatTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetRowInputFormatTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTableSourceITCase.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTableSourceTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/pojo/PojoSimpleRecord.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/ParquetRecordReaderTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverterTest.java
 delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/TestUtil.java
 delete mode 100644 flink-formats/flink-parquet/src/test/resources/avro/nested.avsc
 delete mode 100644 flink-formats/flink-parquet/src/test/resources/avro/simple.avsc