[SPARK-43415] Impl mapValues for KVGDS#mapValues

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 3.5.0
• Component/s: Connect
• Labels: pull-request-available
• Epic Link: Unified SQL Scala Interface
• Assignee: Pengfei Xu
• Reporter: Zhen Li
• Created: 08/May/23 23:05
• Updated: 10/Dec/24 20:22

Description

Use an resolved func to pass the mapValues together with all aggExprs. Then on the server side unfold it to apply mapValues first before running aggregate.

e.g. https://github.com/apache/spark/commit/a234a9b0851ebce87c0ef831b24866f94f0c0d36

Issue Links

• links to: GitHub Pull Request #49111