| 89 | } |
| 90 | |
| 91 | void FilterContext::Insert(TupleRow* row) const noexcept { |
| 92 | if (filter->is_bloom_filter()) { |
| 93 | if (local_bloom_filter == nullptr) return; |
| 94 | void* val = expr_eval->GetValue(row); |
| 95 | uint32_t filter_hash = RawValue::GetHashValueFastHash32( |
| 96 | val, expr_eval->root().type(), RuntimeFilterBank::DefaultHashSeed()); |
| 97 | local_bloom_filter->Insert(filter_hash); |
| 98 | } else if (filter->is_min_max_filter()) { |
| 99 | if (local_min_max_filter == nullptr || local_min_max_filter->AlwaysTrue()) return; |
| 100 | void* val = expr_eval->GetValue(row); |
| 101 | local_min_max_filter->Insert(val); |
| 102 | } else { |
| 103 | DCHECK(filter->is_in_list_filter()); |
| 104 | if (local_in_list_filter == nullptr || local_in_list_filter->AlwaysTrue()) return; |
| 105 | local_in_list_filter->Insert(expr_eval->GetValue(row)); |
| 106 | } |
| 107 | } |
| 108 | |
| 109 | void FilterContext::InsertPerCompareOp(TupleRow* row) const noexcept { |
| 110 | if (filter->getCompareOp() == extdatasource::TComparisonOp::type::EQ) { |