update

Author: Gabriel39

be/src/olap/accept_null_predicate.h

@@ -128,7 +128,7 @@ class AcceptNullPredicate : public ColumnPredicate {
         return row_ranges->count() > 0;
     }
 
-    bool evaluate_del(const ZoneMapInfo& zone_map_info) const override {
+    bool evaluate_del(ZoneMapInfo& zone_map_info) const override {
         return _nested->evaluate_del(zone_map_info);
     }
 

be/src/olap/column_predicate.h

@@ -281,9 +281,9 @@ class ColumnPredicate : public std::enable_shared_from_this<ColumnPredicate> {
 
     virtual bool evaluate_and(ZoneMapInfo& zone_map_info) const { return true; }
 
-    virtual bool is_always_true(const ZoneMapInfo& zone_map_info) const { return false; }
+    virtual bool is_always_true(ZoneMapInfo& zone_map_info) const { return false; }
 
-    virtual bool evaluate_del(const ZoneMapInfo& zone_map_info) const { return false; }
+    virtual bool evaluate_del(ZoneMapInfo& zone_map_info) const { return false; }
 
     virtual bool evaluate_and(BloomFilterInfo& bloom_filter_info) const { return true; }
 

be/src/olap/comparison_predicate.h

@@ -207,7 +207,10 @@ class ComparisonPredicateBase final : public ColumnPredicate {
         return row_ranges->count() > 0;
     }
 
-    bool is_always_true(const ZoneMapInfo& zone_map_info) const override {
+    bool is_always_true(ZoneMapInfo& zone_map_info) const override {
+        if (!(*zone_map_info.get_stat_func)(&zone_map_info, column_id())) {
+            return false;
+        }
         if (zone_map_info.has_null) {
             return false;
         }
@@ -225,7 +228,10 @@ class ComparisonPredicateBase final : public ColumnPredicate {
         return false;
     }
 
-    bool evaluate_del(const ZoneMapInfo& zone_map_info) const override {
+    bool evaluate_del(ZoneMapInfo& zone_map_info) const override {
+        if (!(*zone_map_info.get_stat_func)(&zone_map_info, column_id())) {
+            return false;
+        }
         if (zone_map_info.has_null) {
             return false;
         }

be/src/olap/in_list_predicate.h

@@ -315,7 +315,10 @@ class InListPredicateBase final : public ColumnPredicate {
         return false;
     }
 
-    bool evaluate_del(const ZoneMapInfo& zone_map_info) const override {
+    bool evaluate_del(ZoneMapInfo& zone_map_info) const override {
+        if (!(*zone_map_info.get_stat_func)(&zone_map_info, column_id())) {
+            return false;
+        }
         if (zone_map_info.has_null) {
             return false;
         }

be/src/olap/null_predicate.h

@@ -97,7 +97,10 @@ class NullPredicate final : public ColumnPredicate {
         return row_ranges->count() > 0;
     }
 
-    bool evaluate_del(const ZoneMapInfo& zone_map_info) const override {
+    bool evaluate_del(ZoneMapInfo& zone_map_info) const override {
+        if (!(*zone_map_info.get_stat_func)(&zone_map_info, column_id())) {
+            return false;
+        }
         // evaluate_del only use for delete condition to filter page, need use delete condition origin value,
         // when opposite==true, origin value 'is null'->'is not null' and 'is not null'->'is null',
         // so when _is_null==true, need check 'is not null' and _is_null==false, need check 'is null'

be/src/olap/shared_predicate.h

@@ -111,7 +111,7 @@ class SharedPredicate final : public ColumnPredicate {
         return _nested->evaluate_and(zone_map_info);
     }
 
-    bool evaluate_del(const ZoneMapInfo& zone_map_info) const override {
+    bool evaluate_del(ZoneMapInfo& zone_map_info) const override {
         std::shared_lock<std::shared_mutex> lock(*_mtx);
         if (!_nested) {
             return ColumnPredicate::evaluate_del(zone_map_info);