aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorulya-sidorina <yulia@ydb.tech>2023-08-29 14:22:59 +0300
committerulya-sidorina <yulia@ydb.tech>2023-08-29 15:12:32 +0300
commitb9dd14e58467b9f33380af07f984e7b7105b6d5f (patch)
tree8bb2f5d9caa40a390cd28d8c14a7027e67ae73be
parentb86e0fa1264e4af937a9c1398394fa3196399cab (diff)
downloadydb-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.cpp11
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);
}
}