database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Opt](vectorized) Use new way to do hash shffle to speed up query (#12586)

Browse Source
This commit is contained in:
HappenLee
2022-09-15 11:08:04 +08:00
committed by GitHub
parent 353bb6fdfb
commit e413a2b8e9
20 changed files with 176 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
View File

@ -217,6 +217,8 @@ public class SessionVariable implements Serializable, Writable {
public static final String SKIP_DELETE_PREDICATE = "skip_delete_predicate";
public static final String ENABLE_NEW_SHUFFLE_HASH_METHOD = "enable_new_shuffle_hash_method";
// session origin value
public Map<Field, String> sessionOriginValue = new HashMap<Field, String>();
// check stmt is or not [select /*+ SET_VAR(...)*/ ...]
@ -555,6 +557,8 @@ public class SessionVariable implements Serializable, Writable {
@VariableMgr.VarAttr(name = ENABLE_FALLBACK_TO_ORIGINAL_PLANNER)
public boolean enableFallbackToOriginalPlanner = true;
@VariableMgr.VarAttr(name = ENABLE_NEW_SHUFFLE_HASH_METHOD)
public boolean enableNewShffleHashMethod = true;
public String getBlockEncryptionMode() {
return blockEncryptionMode;
@ -1153,6 +1157,7 @@ public class SessionVariable implements Serializable, Writable {
tResult.setEnableFunctionPushdown(enableFunctionPushdown);
tResult.setFragmentTransmissionCompressionCodec(fragmentTransmissionCompressionCodec);
tResult.setEnableLocalExchange(enableLocalExchange);
tResult.setEnableNewShuffleHashMethod(enableNewShffleHashMethod);
tResult.setSkipStorageEngineMerge(skipStorageEngineMerge);