| 1107 | } |
| 1108 | |
| 1109 | Status BloomFilterPushdownContext::StartProducing(size_t thread_index) { |
| 1110 | if (eval_.num_expected_bloom_filters_ == 0) |
| 1111 | return eval_.all_received_callback_(thread_index); |
| 1112 | return Status::OK(); |
| 1113 | } |
| 1114 | |
| 1115 | Status BloomFilterPushdownContext::BuildBloomFilter(size_t thread_index, |
| 1116 | AccumulationQueue batches, |