Merge 5312027 into a54252c

Author: swalrus1

ydb/core/formats/arrow/rows/view.cpp

@@ -13,6 +13,10 @@ std::partial_ordering TSimpleRow::operator<=>(const TSimpleRow& item) const {
     return TSimpleRowViewV0(Data).Compare(TSimpleRowViewV0(item.Data), Schema).GetResult();
 }
 
+bool TSimpleRow::operator==(const TSimpleRow& item) const {
+    return (*this <=> item) == std::partial_ordering::equivalent;
+}
+
 std::shared_ptr<arrow::RecordBatch> TSimpleRow::ToBatch() const {
     auto builders = NArrow::MakeBuilders(Schema);
     AddToBuilders(builders).Validate();

ydb/core/formats/arrow/rows/view.h

@@ -116,6 +116,7 @@ class TSimpleRow {
     std::partial_ordering CompareNotNull(const TSimpleRow& item) const;
 
     std::partial_ordering operator<=>(const TSimpleRow& item) const;
+    bool operator==(const TSimpleRow& item) const;
 };
 
 }   // namespace NKikimr::NArrow

ydb/core/kqp/ut/common/kqp_ut_common.h

@@ -101,12 +101,14 @@ struct TKikimrSettings: public TTestFeatureFlagsHolder<TKikimrSettings> {
         exchangerSettings->SetMaxDelayMs(10);
         AppConfig.MutableColumnShardConfig()->SetDisabledOnSchemeShard(false);
         AppConfig.MutableColumnShardConfig()->SetMaxInFlightIntervalsOnRequest(1);
+        AppConfig.MutableColumnShardConfig()->SetAlterObjectEnabled(true);
         FeatureFlags.SetEnableSparsedColumns(true);
         FeatureFlags.SetEnableWritePortionsOnInsert(true);
         FeatureFlags.SetEnableParameterizedDecimal(true);
         FeatureFlags.SetEnableTopicAutopartitioningForCDC(true);
         FeatureFlags.SetEnableFollowerStats(true);
         FeatureFlags.SetEnableColumnStore(true);
+        FeatureFlags.SetEnableDuplicateFilterInColumnShard(true);
     }
 
     TKikimrSettings& SetAppConfig(const NKikimrConfig::TAppConfig& value) { AppConfig = value; return *this; }

ydb/core/kqp/ut/olap/aggregations_ut.cpp

@@ -36,6 +36,8 @@ Y_UNIT_TEST_SUITE(KqpOlapAggregations) {
         }
 
         {
+            WriteTestData(kikimr, "/Root/olapStore/olapTable", 10000, 3000000, 1000);
+            WriteTestData(kikimr, "/Root/olapStore/olapTable", 10000, 3000000, 1000);
             WriteTestData(kikimr, "/Root/olapStore/olapTable", 10000, 3000000, 1000);
             WriteTestData(kikimr, "/Root/olapStore/olapTable", 11000, 3001000, 1000);
             WriteTestData(kikimr, "/Root/olapStore/olapTable", 12000, 3002000, 1000);
@@ -99,7 +101,7 @@ Y_UNIT_TEST_SUITE(KqpOlapAggregations) {
             UNIT_ASSERT_C(it.IsSuccess(), it.GetIssues().ToString());
             TString result = StreamResultToYson(it);
             Cout << result << Endl;
-            CompareYson(result, R"([[23000u;]])");
+            CompareYson(result, R"([[25000u;]])");
         }
     }