Merge 878be55 into ffa5093

pavelvelikhov · web-flow · commit 457a58f47105 · 2024-12-05T10:19:40.000Z
diff --git a/ydb/core/kqp/ut/join/kqp_join_order_ut.cpp b/ydb/core/kqp/ut/join/kqp_join_order_ut.cpp
@@ -518,6 +518,11 @@ Y_UNIT_TEST_SUITE(KqpJoinOrder) {
         );
     }
 
+    Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS32, StreamLookupJoin, ColumnStore) {
+        //ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);
+        ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "", StreamLookupJoin, ColumnStore);       
+    }
+
     Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS34, StreamLookupJoin, ColumnStore) {
         ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds34.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);       
     }
diff --git a/yql/essentials/core/arrow_kernels/request/request.cpp b/yql/essentials/core/arrow_kernels/request/request.cpp
@@ -34,6 +34,9 @@ ui32 TKernelRequestBuilder::AddUnaryOp(EUnaryOp op, const TTypeAnnotationNode* a
     case EUnaryOp::Just:
         Items_.emplace_back(Pb_.BlockJust(arg));
         break;
+    case EUnaryOp::Exists:
+        Items_.emplace_back(Pb_.BlockExists(arg));
+        break;
     case EUnaryOp::Size:
     case EUnaryOp::Minus:
     case EUnaryOp::Abs:
diff --git a/yql/essentials/core/arrow_kernels/request/request.h b/yql/essentials/core/arrow_kernels/request/request.h
@@ -13,7 +13,8 @@ class TKernelRequestBuilder {
         Size,
         Minus,
         Abs,
-        Just
+        Just,
+        Exists
     };
 
     enum class EBinaryOp {

Original file line number	Diff line number	Diff line change
`@@ -518,6 +518,11 @@ Y_UNIT_TEST_SUITE(KqpJoinOrder) {`
`518`	`518`	`);`
`519`	`519`	`}`
`520`	`520`
	`521`	`+ Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS32, StreamLookupJoin, ColumnStore) {`
	`522`	`+ //ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);`
	`523`	`+ ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "", StreamLookupJoin, ColumnStore);`
	`524`	`+ }`
	`525`	`+`
`521`	`526`	`Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS34, StreamLookupJoin, ColumnStore) {`
`522`	`527`	`ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds34.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);`
`523`	`528`	`}`
-Original file line number
+Diff line change
         Size,
         Minus,
         Abs,
 -        Just
 +        Just,
 +        Exists
     };
     enum class EBinaryOp {