[SPARK-40050] Enhance EliminateSorts to support removing sorts via LocalLimit

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.4.0
• Fix Version/s: 3.4.0
• Component/s: SQL
• Assignee: Yuming Wang
• Reporter: Yuming Wang
• Created: 12/Aug/22 02:27
• Updated: 20/Aug/22 11:53
• Resolved: 19/Aug/22 12:47

Description

It seems we can remove Sort operator:

    val projectPlan = testRelation.select($"a", $"b")
    val unnecessaryOrderByPlan = projectPlan.orderBy($"a".asc)
    val localLimitPlan = LocalLimit(Literal(2), unnecessaryOrderByPlan)
    val projectPlanB = testRelationB.select($"d")
    val joinPlan = localLimitPlan.join(projectPlanB, RightOuter).select($"a", $"d")

Issue Links

• is duplicated by: SPARK-40080 Adds additional EliminateSorts before LimitPushDown
• links to: [Github] Pull Request #37519 (wangyum)
• links to: [Github] Pull Request #37519 (wangyum)