test: proof that once apache#12032 merges, the PR for apache#12232 wi…

…ll solve the issue
influxdata · Aug 29, 2024 · a1edaa0 · a1edaa0
1 parent 8cef364
commit a1edaa0
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs
@@ -2090,11 +2090,8 @@ mod tests {
         Ok(())
     }
 
-    /// parquet's get_data_page_statistics is not yet implemented
-    /// for view types.
-    #[should_panic(expected = "not implemented")]
     #[tokio::test]
-    async fn test_struct_filter_parquet_with_view_types() {
+    async fn test_struct_filter_parquet_with_view_types() -> Result<()> {
         let tmp_dir = TempDir::new().unwrap();
         let path = tmp_dir.path().to_str().unwrap().to_string() + "/test.parquet";
         write_file(&path);
@@ -2110,7 +2107,17 @@ mod tests {
             .await
             .unwrap();
         let sql = "select * from base_table where name='test02'";
-        let _ = ctx.sql(sql).await.unwrap().collect().await.unwrap();
+        let batch = ctx.sql(sql).await.unwrap().collect().await.unwrap();
+        assert_eq!(batch.len(), 1);
+        let expected = [
+            "+---------------------+----+--------+",
+            "| struct              | id | name   |",
+            "+---------------------+----+--------+",
+            "| {id: 4, name: aaa2} | 2  | test02 |",
+            "+---------------------+----+--------+",
+        ];
+        crate::assert_batches_eq!(expected, &batch);
+        Ok(())
     }
 
     fn write_file(file: &String) {