diff options
author | ulya-sidorina <yulia@ydb.tech> | 2023-08-29 14:22:59 +0300 |
---|---|---|
committer | ulya-sidorina <yulia@ydb.tech> | 2023-08-29 15:12:32 +0300 |
commit | b9dd14e58467b9f33380af07f984e7b7105b6d5f (patch) | |
tree | 8bb2f5d9caa40a390cd28d8c14a7027e67ae73be | |
parent | b86e0fa1264e4af937a9c1398394fa3196399cab (diff) | |
download | ydb-b9dd14e58467b9f33380af07f984e7b7105b6d5f.tar.gz |
KIKIMR-19176: fix skip null members for point lookup
fix(kqp): use correct skip null members for point lookup
-rw-r--r-- | ydb/core/kqp/opt/logical/kqp_opt_log_ranges.cpp | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/ydb/core/kqp/opt/logical/kqp_opt_log_ranges.cpp b/ydb/core/kqp/opt/logical/kqp_opt_log_ranges.cpp index 841794f6254..2ec0a4ac03b 100644 --- a/ydb/core/kqp/opt/logical/kqp_opt_log_ranges.cpp +++ b/ydb/core/kqp/opt/logical/kqp_opt_log_ranges.cpp @@ -395,9 +395,16 @@ TExprBase KqpRewriteLookupTable(const TExprBase& node, TExprContext& ctx, const auto it = keyColumnsStruct.find(name); YQL_ENSURE(it != keyColumnsStruct.end()); keyValues.push_back(it->second); + } + + if (skipNullMembers) { + auto skipNullColumns = skipNullMembers.Cast().Members(); + + if (skipNullColumns) { + for (const auto &column : skipNullColumns.Cast()) { + settings.AddSkipNullKey(TString(column.Value())); + } - if (skipNullMembers) { - settings.AddSkipNullKey(name); } } |