We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 858c0ec commit d36f2f0Copy full SHA for d36f2f0
sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala
@@ -201,7 +201,7 @@ object SortExec {
201
val prefixComputer = new UnsafeExternalRowSorter.PrefixComputer {
202
private val result = new UnsafeExternalRowSorter.PrefixComputer.Prefix
203
override def computePrefix(row: InternalRow):
204
- UnsafeExternalRowSorter.PrefixComputer.Prefix = {
+ UnsafeExternalRowSorter.PrefixComputer.Prefix = {
205
val prefix = prefixProjection.apply(row)
206
result.isNull = prefix.isNullAt(0)
207
result.value = if (result.isNull) prefixExpr.nullValue else prefix.getLong(0)
0 commit comments