File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -85,9 +85,9 @@ BloomFilter::BloomFilter(const uint8_t* data, size_t size) {
8585 offset += sizeof (uint64_t );
8686
8787 // Validate header fields before using them
88- constexpr size_t MAX_BITS = (1ULL << 40 ); // ~1TB max, reasonable upper bound
89- constexpr size_t MAX_HASHES = 64 ; // reasonable upper bound
90- constexpr size_t MAX_EXPECTED = (1ULL << 30 ); // ~1B elements max
88+ constexpr size_t MAX_BITS = (1ULL << 40 ); // ~1TB max, reasonable upper bound
89+ constexpr size_t MAX_HASHES = 64 ; // reasonable upper bound
90+ constexpr size_t MAX_EXPECTED = (1ULL << 30 ); // ~1B elements max
9191
9292 if (num_bits_ == 0 || num_bits_ > MAX_BITS) {
9393 num_bits_ = 0 ;
Original file line number Diff line number Diff line change @@ -578,10 +578,12 @@ int main(int argc, char* argv[]) {
578578
579579 if (cluster_manager->has_bloom_filter (args.context_id )) {
580580 bloom = cluster_manager->get_bloom_filter (args.context_id );
581- std::string probe_key_col = cluster_manager->get_probe_key_col (args.context_id );
581+ std::string probe_key_col =
582+ cluster_manager->get_probe_key_col (args.context_id );
582583
583584 if (!probe_key_col.empty ()) {
584- auto table_meta_opt = catalog->get_table_by_name (args.table_name );
585+ auto table_meta_opt =
586+ catalog->get_table_by_name (args.table_name );
585587 if (table_meta_opt.has_value ()) {
586588 const auto * table_meta = table_meta_opt.value ();
587589 for (size_t i = 0 ; i < table_meta->columns .size (); ++i) {
@@ -614,7 +616,8 @@ int main(int argc, char* argv[]) {
614616 }
615617
616618 // Apply bloom filter on sender side before sending
617- std::vector<cloudsql::executor::Tuple> rows_to_send = std::move (rows);
619+ std::vector<cloudsql::executor::Tuple> rows_to_send =
620+ std::move (rows);
618621 if (have_bloom) {
619622 std::vector<cloudsql::executor::Tuple> filtered;
620623 filtered.reserve (rows_to_send.size ());
You can’t perform that action at this time.
0 commit comments