[fix](inverted index) fixed in_list condition not indexed on pipelinex#36565
[fix](inverted index) fixed in_list condition not indexed on pipelinex#36565qidaye merged 1 commit intoapache:masterfrom
Conversation
|
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
|
run buildall |
| template <typename Derived> | ||
| template <PrimitiveType T> | ||
| Status ScanLocalState<Derived>::_normalize_binary_in_compound_predicate( | ||
| Status ScanLocalState<Derived>::_normalize_binary_compound_predicate( |
There was a problem hiding this comment.
warning: function '_normalize_binary_compound_predicate' has cognitive complexity of 54 (threshold 50) [readability-function-cognitive-complexity]
Status ScanLocalState<Derived>::_normalize_binary_compound_predicate(
^Additional context
be/src/pipeline/exec/scan_operator.cpp:1044: +1, including nesting penalty of 0, nesting level increased to 1
if (TExprNodeType::BINARY_PRED == expr->node_type()) {
^be/src/pipeline/exec/scan_operator.cpp:1045: nesting level increased to 2
auto eq_checker = [](const std::string& fn_name) { return fn_name == "eq"; };
^be/src/pipeline/exec/scan_operator.cpp:1046: nesting level increased to 2
auto ne_checker = [](const std::string& fn_name) { return fn_name == "ne"; };
^be/src/pipeline/exec/scan_operator.cpp:1047: nesting level increased to 2
auto noneq_checker = [](const std::string& fn_name) {
^be/src/pipeline/exec/scan_operator.cpp:1048: +1
return fn_name != "ne" && fn_name != "eq" && fn_name != "eq_for_null";
^be/src/pipeline/exec/scan_operator.cpp:1056: +2, including nesting penalty of 1, nesting level increased to 2
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:626: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/scan_operator.cpp:1056: +3, including nesting penalty of 2, nesting level increased to 3
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:628: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/scan_operator.cpp:1059: +2, including nesting penalty of 1, nesting level increased to 2
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:626: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/scan_operator.cpp:1059: +3, including nesting penalty of 2, nesting level increased to 3
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:628: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/scan_operator.cpp:1062: +2, including nesting penalty of 1, nesting level increased to 2
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:626: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/scan_operator.cpp:1062: +3, including nesting penalty of 2, nesting level increased to 3
RETURN_IF_ERROR(_should_push_down_binary_predicate(
^be/src/common/status.h:628: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/scan_operator.cpp:1065: +2, including nesting penalty of 1, nesting level increased to 2
if (eq_pdt == PushDownType::UNACCEPTABLE && ne_pdt == PushDownType::UNACCEPTABLE &&
^be/src/pipeline/exec/scan_operator.cpp:1065: +1
if (eq_pdt == PushDownType::UNACCEPTABLE && ne_pdt == PushDownType::UNACCEPTABLE &&
^be/src/pipeline/exec/scan_operator.cpp:1072: +2, including nesting penalty of 1, nesting level increased to 2
if (eq_pdt == PushDownType::ACCEPTABLE || ne_pdt == PushDownType::ACCEPTABLE ||
^be/src/pipeline/exec/scan_operator.cpp:1072: +1
if (eq_pdt == PushDownType::ACCEPTABLE || ne_pdt == PushDownType::ACCEPTABLE ||
^be/src/pipeline/exec/scan_operator.cpp:1074: +3, including nesting penalty of 2, nesting level increased to 3
if (value.data != nullptr) {
^be/src/pipeline/exec/scan_operator.cpp:1075: +4, including nesting penalty of 3, nesting level increased to 4
if constexpr (T == TYPE_CHAR || T == TYPE_VARCHAR || T == TYPE_STRING ||
^be/src/pipeline/exec/scan_operator.cpp:1075: +1
if constexpr (T == TYPE_CHAR || T == TYPE_VARCHAR || T == TYPE_STRING ||
^be/src/pipeline/exec/scan_operator.cpp:1078: +5, including nesting penalty of 4, nesting level increased to 5
RETURN_IF_ERROR(_change_value_range<false>(
^be/src/common/status.h:626: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/scan_operator.cpp:1078: +6, including nesting penalty of 5, nesting level increased to 6
RETURN_IF_ERROR(_change_value_range<false>(
^be/src/common/status.h:628: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^be/src/pipeline/exec/scan_operator.cpp:1082: +1, nesting level increased to 4
} else {
^be/src/pipeline/exec/scan_operator.cpp:1083: +5, including nesting penalty of 4, nesting level increased to 5
RETURN_IF_ERROR(_change_value_range<false>(
^be/src/common/status.h:626: expanded from macro 'RETURN_IF_ERROR'
do { \
^be/src/pipeline/exec/scan_operator.cpp:1083: +6, including nesting penalty of 5, nesting level increased to 6
RETURN_IF_ERROR(_change_value_range<false>(
^be/src/common/status.h:628: expanded from macro 'RETURN_IF_ERROR'
if (UNLIKELY(!_status_.ok())) { \
^| return Status::OK(); | ||
| } | ||
| } else { | ||
| vectorized::VInPredicate* pred = static_cast<vectorized::VInPredicate*>(expr); |
There was a problem hiding this comment.
warning: use auto when initializing with a cast to avoid duplicating the type name [modernize-use-auto]
| vectorized::VInPredicate* pred = static_cast<vectorized::VInPredicate*>(expr); | |
| auto* pred = static_cast<vectorized::VInPredicate*>(expr); |
| } else { | ||
| vectorized::VInPredicate* pred = static_cast<vectorized::VInPredicate*>(expr); | ||
|
|
||
| vectorized::InState* state = reinterpret_cast<vectorized::InState*>( |
There was a problem hiding this comment.
warning: use auto when initializing with a cast to avoid duplicating the type name [modernize-use-auto]
| vectorized::InState* state = reinterpret_cast<vectorized::InState*>( | |
| auto* state = reinterpret_cast<vectorized::InState*>( |
|
TeamCity be ut coverage result: |
TPC-H: Total hot run time: 39902 ms |
TPC-DS: Total hot run time: 172285 ms |
ClickBench: Total hot run time: 30.72 s |
|
run buildall |
|
TeamCity be ut coverage result: |
TPC-H: Total hot run time: 39739 ms |
|
run buildall |
TPC-H: Total hot run time: 40533 ms |
TPC-DS: Total hot run time: 169640 ms |
|
TeamCity be ut coverage result: |
ClickBench: Total hot run time: 30.14 s |
|
PR approved by at least one committer and no changes requested. |
|
PR approved by anyone and no changes requested. |
|
run p0 |
|
run p0 |
|
run buildall |
|
TeamCity be ut coverage result: |
TPC-H: Total hot run time: 40099 ms |
|
run performance |
TPC-H: Total hot run time: 39672 ms |
TPC-DS: Total hot run time: 173831 ms |
ClickBench: Total hot run time: 30.57 s |
|
PR approved by at least one committer and no changes requested. |
Proposed changes
Issue Number: close #xxx