Consolidate ParquetExec tests in parquet_exec integration test (#4130)

* Consolidate `ParquetExec` tests in `parquet_exec` integration test

* improve comment

Author: alamb

datafusion/core/src/physical_plan/file_format/parquet.rs

@@ -900,6 +900,8 @@ pub async fn plan_to_parquet(
 
 #[cfg(test)]
 mod tests {
+    // See also `parquet_exec` integration test
+
     use super::*;
     use crate::config::ConfigOptions;
     use crate::datasource::file_format::parquet::test_util::store_parquet;

datafusion/core/tests/parquet/repeat_much.snappy.parquet renamed to datafusion/core/tests/parquet/data/repeat_much.snappy.parquet

@@ -272,7 +272,7 @@ async fn single_file_small_data_pages() {
 
     // TestCase::new(&test_parquet_file)
     //     .with_name("selective")
-    //     // predicagte is chosen carefully to prune pages 0, 1, 2, 3, 4
+    //     // predicate is chosen carefully to prune pages 0, 1, 2, 3, 4
     //     // pod = 'iadnalqpdzthpifrvewossmpqibgtsuin'
     //     .with_filter(col("pod").eq(lit("iadnalqpdzthpifrvewossmpqibgtsuin")))
     //     .with_pushdown_expected(PushdownExpected::Some)
@@ -291,7 +291,7 @@ async fn single_file_small_data_pages() {
     // page 5:                                     DLE:RLE RLE:RLE VLE:RLE_DICTIONARY ST:[min: 1970-01-01T00:00:00.000000000, max: 1970-01-01T00:00:00.005330944, num_nulls not defined] CRC:[none] SZ:12601 VC:7739
     TestCase::new(&test_parquet_file)
         .with_name("selective")
-        // predicagte is chosen carefully to prune pages
+        // predicate is chosen carefully to prune pages 1, 2, 4, and 5
         // time > 1970-01-01T00:00:00.004300000
         .with_filter(col("time").gt(lit_timestamp_nano(4300000)))
         .with_pushdown_expected(PushdownExpected::Some)

datafusion/core/tests/parquet/test_binary.parquet renamed to datafusion/core/tests/parquet/data/test_binary.parquet

@@ -0,0 +1,21 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+//! Parquet integration tests
+mod filter_pushdown;
+mod page_pruning;
+mod row_group_pruning;

datafusion/core/tests/parquet_filter_pushdown.rs renamed to datafusion/core/tests/parquet/filter_pushdown.rs

@@ -0,0 +1,19 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+/// Run all tests that are found in the `parquet` directory
+mod parquet;

datafusion/core/tests/parquet/mod.rs

@@ -214,7 +214,7 @@ async fn sort_empty() -> Result<()> {
 #[tokio::test]
 async fn sort_with_lots_of_repetition_values() -> Result<()> {
     let ctx = SessionContext::new();
-    let filename = "tests/parquet/repeat_much.snappy.parquet";
+    let filename = "tests/parquet/data/repeat_much.snappy.parquet";
 
     ctx.register_parquet("rep", filename, ParquetReadOptions::default())
         .await?;

datafusion/core/tests/parquet_page_index_pruning.rs renamed to datafusion/core/tests/parquet/page_pruning.rs

@@ -53,7 +53,7 @@ async fn fixed_size_binary_columns() {
     let ctx = SessionContext::new();
     ctx.register_parquet(
         "t0",
-        "tests/parquet/test_binary.parquet",
+        "tests/parquet/data/test_binary.parquet",
         ParquetReadOptions::default(),
     )
     .await