@@ -421,13 +421,13 @@ class OpenAddressHashAgg {
421421 bool has_float_value[MAX_AGGREGATES ] = {false };
422422 int64_t mins[MAX_AGGREGATES ] = {0 };
423423 int64_t maxes[MAX_AGGREGATES ] = {0 };
424- bool has_mins[MAX_AGGREGATES ] = {false }; // Track if initialized
425- double mins_float64[MAX_AGGREGATES ] = {0.0 }; // Float MIN accumulator
426- double maxes_float64[MAX_AGGREGATES ] = {0.0 }; // Float MAX accumulator
424+ bool has_mins[MAX_AGGREGATES ] = {false }; // Track if initialized
425+ double mins_float64[MAX_AGGREGATES ] = {0.0 }; // Float MIN accumulator
426+ double maxes_float64[MAX_AGGREGATES ] = {0.0 }; // Float MAX accumulator
427427 bool has_float_minmax[MAX_AGGREGATES ] = {false }; // Track if float MIN/MAX initialized
428- uint8_t key_type = 0 ; // 0x02=INT64, 0x04=STRING
429- uint32_t key_len = 0 ; // For non-int64 keys
430- uint8_t key_data[64 ]; // Stored key bytes for iteration
428+ uint8_t key_type = 0 ; // 0x02=INT64, 0x04=STRING
429+ uint32_t key_len = 0 ; // For non-int64 keys
430+ uint8_t key_data[64 ]; // Stored key bytes for iteration
431431 };
432432
433433 std::vector<HashBucket> buckets_;
@@ -691,8 +691,8 @@ class DirectIndexAgg {
691691 int64_t mins[MAX_AGGREGATES ] = {0 };
692692 int64_t maxes[MAX_AGGREGATES ] = {0 };
693693 bool has_mins[MAX_AGGREGATES ] = {false };
694- double mins_float64[MAX_AGGREGATES ] = {0.0 }; // Float MIN accumulator
695- double maxes_float64[MAX_AGGREGATES ] = {0.0 }; // Float MAX accumulator
694+ double mins_float64[MAX_AGGREGATES ] = {0.0 }; // Float MIN accumulator
695+ double maxes_float64[MAX_AGGREGATES ] = {0.0 }; // Float MAX accumulator
696696 bool has_float_minmax[MAX_AGGREGATES ] = {false }; // Track if float MIN/MAX initialized
697697 };
698698
@@ -1173,8 +1173,9 @@ class VectorizedGroupByOperator : public VectorizedOperator {
11731173 // Find first valid group slot with output pending
11741174 for (size_t idx : agg_.valid_slots ()) {
11751175 auto & slot = agg_.slot (idx);
1176- if (!slot.emitted && (slot.counts [0 ] > 0 || (slot.valid && aggregates_[0 ].type == AggregateType::Count &&
1177- aggregates_[0 ].input_col_idx < 0 ))) {
1176+ if (!slot.emitted &&
1177+ (slot.counts [0 ] > 0 || (slot.valid && aggregates_[0 ].type == AggregateType::Count &&
1178+ aggregates_[0 ].input_col_idx < 0 ))) {
11781179 // Found a group with data
11791180 // int8 range: -128 to 127
11801181 int64_t key = static_cast <int64_t >(static_cast <int8_t >(idx));
0 commit comments