aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraneporada <aneporada@ydb.tech>2023-02-21 19:36:25 +0300
committeraneporada <aneporada@ydb.tech>2023-02-21 19:36:25 +0300
commit40717b186524f698361f094ebd1cf2753419a334 (patch)
tree5da60f2536d324d9d07aa25961c7be31ce275142
parent45c92b417719aba5e3d24726c699b979c6b8ab98 (diff)
downloadydb-40717b186524f698361f094ebd1cf2753419a334.tar.gz
Fix nullability bitmap breakage intoroduced in rXXXXXX
-rw-r--r--ydb/library/yql/public/udf/arrow/block_builder.h16
1 files changed, 8 insertions, 8 deletions
diff --git a/ydb/library/yql/public/udf/arrow/block_builder.h b/ydb/library/yql/public/udf/arrow/block_builder.h
index bcbd97361f..8113a7ee10 100644
--- a/ydb/library/yql/public/udf/arrow/block_builder.h
+++ b/ydb/library/yql/public/udf/arrow/block_builder.h
@@ -360,7 +360,7 @@ public:
if constexpr (Nullable) {
Y_VERIFY(NullBuilder->Length() == DataBuilder->Length());
for (size_t i = beginIndex; i < beginIndex + count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, i));
+ NullBuilder->UnsafeAppend(!IsNull(array, i));
}
}
@@ -375,7 +375,7 @@ public:
if constexpr (Nullable) {
Y_VERIFY(NullBuilder->Length() == DataBuilder->Length());
for (size_t i = 0; i < count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, indexes[i]));
+ NullBuilder->UnsafeAppend(!IsNull(array, indexes[i]));
}
}
@@ -593,7 +593,7 @@ public:
for (;;) {
if (strSize <= availBytes) {
if constexpr (Nullable) {
- NullBuilder->UnsafeAppend(IsNull(array, i));
+ NullBuilder->UnsafeAppend(!IsNull(array, i));
}
OffsetsBuilder->UnsafeAppend(TOffset(dataLen));
chunkEnd = end;
@@ -634,7 +634,7 @@ public:
for (;;) {
if (str.size() <= availBytes) {
if constexpr (Nullable) {
- NullBuilder->UnsafeAppend(IsNull(array, idx));
+ NullBuilder->UnsafeAppend(!IsNull(array, idx));
}
OffsetsBuilder->UnsafeAppend(TOffset(dataLen));
DataBuilder->UnsafeAppend((const ui8*)str.data(), str.size());
@@ -805,7 +805,7 @@ public:
if constexpr (Nullable) {
for (ui64 i = beginIndex; i < beginIndex + count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, i));
+ NullBuilder->UnsafeAppend(!IsNull(array, i));
}
}
@@ -820,7 +820,7 @@ public:
if constexpr (Nullable) {
for (size_t i = 0; i < count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, indexes[i]));
+ NullBuilder->UnsafeAppend(!IsNull(array, indexes[i]));
}
}
@@ -933,7 +933,7 @@ public:
Y_VERIFY(array.child_data.size() == 1);
for (ui64 i = beginIndex; i < beginIndex + count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, i));
+ NullBuilder->UnsafeAppend(!IsNull(array, i));
}
Inner->AddMany(*array.child_data[0], beginIndex, count);
@@ -944,7 +944,7 @@ public:
Y_VERIFY(array.child_data.size() == 1);
for (size_t i = 0; i < count; ++i) {
- NullBuilder->UnsafeAppend(IsNull(array, indexes[i]));
+ NullBuilder->UnsafeAppend(!IsNull(array, indexes[i]));
}
Inner->AddMany(*array.child_data[0], indexes, count);