Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -332,18 +332,20 @@ class CometNativeReaderSuite extends CometTestBase with AdaptiveSparkPlanHelper
"select map_keys(c0).b from tbl")
}

// commented out because of correctness issue https://github.com/apache/datafusion-comet/issues/1789
// test("native reader - select nested field from a complex map[struct, struct] using map_values") {
// testSingleLineQuery(
// """
// | select map(str0, str1) c0 from
// | (
// | select named_struct('a', cast(1 as long), 'b', cast(2 as long), 'c', cast(3 as long)) str0,
// | named_struct('x', cast(8 as long), 'y', cast(9 as long), 'z', cast(0 as long)) str1 union all
// | select named_struct('a', cast(3 as long), 'b', cast(4 as long), 'c', cast(5 as long)) str0,
// | named_struct('x', cast(6 as long), 'y', cast(7 as long), 'z', cast(8 as long)) str1
// | )
// |""".stripMargin,
// "select map_values(c0).b from tbl")
// }
// Note: commented out for comet native result because of correctness issue https://github.com/apache/datafusion-comet/issues/1789
// But now we fall back to Spark for this query in https://github.com/apache/datafusion-comet/pull/1799 , so it is not an issue currently.
test(
"native reader - select nested field from a complex map[struct, struct] using map_values") {
testSingleLineQuery(
"""
| select map(str0, str1) c0 from
| (
| select named_struct('a', cast(1 as long), 'b', cast(2 as long), 'c', cast(3 as long)) str0,
| named_struct('x', cast(8 as long), 'y', cast(9 as long), 'z', cast(0 as long)) str1 union all
| select named_struct('a', cast(3 as long), 'b', cast(4 as long), 'c', cast(5 as long)) str0,
| named_struct('x', cast(6 as long), 'y', cast(7 as long), 'z', cast(8 as long)) str1
| )
|""".stripMargin,
"select map_values(c0).b from tbl")
}
}
Loading