diff options
Diffstat (limited to 'sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java')
-rw-r--r-- | sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java b/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java index 7784345a7a..8d9906da7e 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java @@ -59,7 +59,8 @@ public final class UnsafeExternalRowSorter { Ordering<InternalRow> ordering, PrefixComparator prefixComparator, PrefixComputer prefixComputer, - long pageSizeBytes) throws IOException { + long pageSizeBytes, + boolean canUseRadixSort) throws IOException { this.schema = schema; this.prefixComputer = prefixComputer; final SparkEnv sparkEnv = SparkEnv.get(); @@ -72,7 +73,8 @@ public final class UnsafeExternalRowSorter { new RowComparator(ordering, schema.length()), prefixComparator, /* initialSize */ 4096, - pageSizeBytes + pageSizeBytes, + canUseRadixSort ); } |