aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java
diff options
context:
space:
mode:
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.java6
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
);
}