Skip to content

Commit efd604a

Browse files
committed
Add spill related session property for native engine
1 parent 1c14dff commit efd604a

2 files changed

Lines changed: 9 additions & 0 deletions

File tree

‎presto-main/src/main/java/com/facebook/presto/SystemSessionProperties.java‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -328,6 +328,7 @@ public final class SystemSessionProperties
328328
public static final String NATIVE_WRITER_SPILL_ENABLED = "native_writer_spill_enabled";
329329
public static final String NATIVE_ROW_NUMBER_SPILL_ENABLED = "native_row_number_spill_enabled";
330330
public static final String NATIVE_TOPN_ROW_NUMBER_SPILL_ENABLED = "native_topn_row_number_spill_enabled";
331+
public static final String NATIVE_JOIN_SPILLER_PARTITION_BITS = "native_join_spiller_partition_bits";
331332
public static final String NATIVE_EXECUTION_ENABLED = "native_execution_enabled";
332333
public static final String NATIVE_EXECUTION_EXECUTABLE_PATH = "native_execution_executable_path";
333334
public static final String NATIVE_EXECUTION_PROGRAM_ARGUMENTS = "native_execution_program_arguments";
@@ -1635,6 +1636,12 @@ public SystemSessionProperties(
16351636
"Native Execution only. Enable topN row number spilling on native engine",
16361637
false,
16371638
false),
1639+
integerProperty(
1640+
NATIVE_JOIN_SPILLER_PARTITION_BITS,
1641+
"Native Execution only. The number of bits (N) used to calculate the " +
1642+
"spilling partition number for hash join and RowNumber: 2 ^ N",
1643+
2,
1644+
false),
16381645
booleanProperty(
16391646
NATIVE_EXECUTION_ENABLED,
16401647
"Enable execution on native engine",

‎presto-native-execution/presto_cpp/main/QueryContextManager.cpp‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ std::string toVeloxConfig(const std::string& name) {
5252
{"native_writer_spill_enabled", QueryConfig::kWriterSpillEnabled},
5353
{"native_row_number_spill_enabled",
5454
QueryConfig::kRowNumberSpillEnabled},
55+
{"native_join_spiller_partition_bits",
56+
QueryConfig::kJoinSpillPartitionBits},
5557
{"native_topn_row_number_spill_enabled",
5658
QueryConfig::kTopNRowNumberSpillEnabled},
5759
{"native_debug_validate_output_from_operators",

0 commit comments

Comments
 (0)