Skip to content

Commit 03bf540

Browse files
committed
Address comments.
1 parent d684a0f commit 03bf540

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaPruningSuite.scala

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ class ParquetSchemaPruningSuite
185185
checkAnswer(query4, Row("Jane", "abc") :: Nil)
186186
}
187187

188-
testSchemaPruning("select nullable complex field and having is null predicate") {
188+
testSchemaPruning("select nullable complex field and having is not null predicate") {
189189
val query = sql("select employer.company from contacts " +
190190
"where employer is not null and p = 1")
191191
checkScan(query, "struct<employer:struct<company:struct<name:string,address:string>>>")
@@ -300,10 +300,7 @@ class ParquetSchemaPruningSuite
300300

301301
testMixedCasePruning("filter with different-case column names") {
302302
val query = sql("select id from mixedcase where Col2.b = 2")
303-
// Pruning with filters is currently unsupported. As-is, the file reader will read the id column
304-
// and the entire coL2 struct. Once pruning with filters has been implemented we can uncomment
305-
// this line
306-
// checkScan(query, "struct<id:int,coL2:struct<B:int>>")
303+
checkScan(query, "struct<id:int,coL2:struct<B:int>>")
307304
checkAnswer(query.orderBy("id"), Row(1) :: Nil)
308305
}
309306

0 commit comments

Comments
 (0)