Initial commit

pavelvelikhov · pavelvelikhov · commit 878be55993db · 2024-12-05T10:18:54.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
@@ -481,6 +481,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
`@@ -481,6 +481,11 @@ Y_UNIT_TEST_SUITE(KqpJoinOrder) {`
`481`	`481`	`);`
`482`	`482`	`}`
`483`	`483`
	`484`	`+ Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS32, StreamLookupJoin, ColumnStore) {`
	`485`	`+ //ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);`
	`486`	`+ ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds32.sql", "", StreamLookupJoin, ColumnStore);`
	`487`	`+ }`
	`488`	`+`
`484`	`489`	`Y_UNIT_TEST_XOR_OR_BOTH_FALSE(TPCDS34, StreamLookupJoin, ColumnStore) {`
`485`	`490`	`ExecuteJoinOrderTestDataQueryWithStats("queries/tpcds34.sql", "stats/tpcds1000s.json", StreamLookupJoin, ColumnStore);`
`486`	`491`	`}`
-Original file line number
+Diff line change
         Size,
         Minus,
         Abs,
 -        Just
 +        Just,
 +        Exists
     };
     enum class EBinaryOp {