Skip to content
This repository has been archived by the owner on Sep 18, 2023. It is now read-only.

[NSE-784] fallback Sort after SortHashAgg #780

Merged
merged 3 commits into from
Mar 22, 2022
Merged

[NSE-784] fallback Sort after SortHashAgg #780

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
7e2788e
fallback Sort after SortHashAgg
zhouyuan Mar 21, 2022
31d89ff
Revert "fallback Sort after SortHashAgg"
zhouyuan Mar 22, 2022
419cee8
fix sort with expand
zhouyuan Mar 22, 2022
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
4 changes: 4 additions & 0 deletions native-sql-engine/core/src/main/scala/com/intel/oap/extension/ColumnarOverrides.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,10 @@ case class ColumnarPreOverrides() extends Rule[SparkPlan] {
case plan: SortExec =>
val child = replaceWithColumnarPlan(plan.child)
logDebug(s"Columnar Processing for ${plan.getClass} is currently supported.")
if (child.isInstanceOf[ExpandExec]) {
//FIXME: quick for Sort spill bug
return plan.withNewChildren(Seq(child))
}
child match {
case p: CoalesceBatchesExec =>
ColumnarSortExec(plan.sortOrder, plan.global, p.child, plan.testSpillFrequency)
Expand Down