@@ -564,10 +564,11 @@ class OpenAddressHashAgg {
564564
565565 for (size_t i = 0 ; i < old_buckets.size (); ++i) {
566566 if (old_buckets[i].occupied ) {
567- auto & dst = (old_buckets[i].key_type == 0x02 )
568- ? find_or_insert_int64 (old_buckets[i].key_int64 , old_buckets[i].key_hash )
569- : find_or_insert (old_buckets[i].key_data , old_buckets[i].key_len ,
570- old_buckets[i].key_hash );
567+ auto & dst =
568+ (old_buckets[i].key_type == 0x02 )
569+ ? find_or_insert_int64 (old_buckets[i].key_int64 , old_buckets[i].key_hash )
570+ : find_or_insert (old_buckets[i].key_data , old_buckets[i].key_len ,
571+ old_buckets[i].key_hash );
571572 // Copy accumulators from old bucket to new bucket
572573 for (size_t j = 0 ; j < max_aggregates_; ++j) {
573574 dst.counts [j] = old_buckets[i].counts [j];
@@ -1206,12 +1207,13 @@ class VectorizedGroupByOperator : public VectorizedOperator {
12061207 int64_t val;
12071208 std::memcpy (&val, &bucket.key_data [key_offset], 8 );
12081209 out_batch.get_column (c).append (common::Value::make_int64 (val));
1209- key_offset += 9 ; // 1 byte tag + 8 bytes
1210+ key_offset += 9 ; // 1 byte tag + 8 bytes
12101211 } else if (type_tag == 0x04 ) { // STRING
12111212 uint32_t str_len;
12121213 std::memcpy (&str_len, &bucket.key_data [key_offset], 4 );
12131214 key_offset += 4 ;
1214- std::string val (reinterpret_cast <const char *>(&bucket.key_data [key_offset]), str_len);
1215+ std::string val (reinterpret_cast <const char *>(&bucket.key_data [key_offset]),
1216+ str_len);
12151217 out_batch.get_column (c).append (common::Value::make_text (val));
12161218 key_offset += str_len;
12171219 } else {
0 commit comments