[opt](inverted index) add session variable enable_inverted_index_query to control whether query with inverted index (#22255)

This commit is contained in:
YueW
2023-07-28 12:43:26 +08:00
committed by GitHub
parent 5da5fac37a
commit 7be349a10b
5 changed files with 34 additions and 0 deletions

View File

@ -310,6 +310,8 @@ public class SessionVariable implements Serializable, Writable {
public static final String FILE_CACHE_BASE_PATH = "file_cache_base_path";
public static final String ENABLE_INVERTED_INDEX_QUERY = "enable_inverted_index_query";
public static final String GROUP_BY_AND_HAVING_USE_ALIAS_FIRST = "group_by_and_having_use_alias_first";
public static final String DROP_TABLE_IF_CTAS_FAILED = "drop_table_if_ctas_failed";
@ -962,6 +964,11 @@ public class SessionVariable implements Serializable, Writable {
+ "and randomly select the storage path configured by BE."})
public String fileCacheBasePath = "random";
// Whether enable query with inverted index.
@VariableMgr.VarAttr(name = ENABLE_INVERTED_INDEX_QUERY, needForward = true, description = {
"是否启用inverted index query。", "Set wether to use inverted index query."})
public boolean enableInvertedIndexQuery = true;
// Whether drop table when create table as select insert data appear error.
@VariableMgr.VarAttr(name = DROP_TABLE_IF_CTAS_FAILED, needForward = true)
public boolean dropTableIfCtasFailed = true;
@ -1994,6 +2001,14 @@ public class SessionVariable implements Serializable, Writable {
this.fileCacheBasePath = basePath;
}
public boolean isEnableInvertedIndexQuery() {
return enableInvertedIndexQuery;
}
public void setEnableInvertedIndexQuery(boolean enableInvertedIndexQuery) {
this.enableInvertedIndexQuery = enableInvertedIndexQuery;
}
public int getMaxTableCountUseCascadesJoinReorder() {
return this.maxTableCountUseCascadesJoinReorder;
}
@ -2087,6 +2102,8 @@ public class SessionVariable implements Serializable, Writable {
tResult.setFileCacheBasePath(fileCacheBasePath);
tResult.setEnableInvertedIndexQuery(enableInvertedIndexQuery);
if (dryRunQuery) {
tResult.setDryRunQuery(true);
}