Skip to content

Commit 5c8ba22

Browse files
duckdblabs-botgithub-actions[bot]
authored andcommitted
Update vendored DuckDB sources to c8906e701e
1 parent 538eb67 commit 5c8ba22

File tree

324 files changed

+896
-2037
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

324 files changed

+896
-2037
lines changed

CMakeLists.txt

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

src/duckdb/extension/core_functions/aggregate/distributive/arg_min_max.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,7 @@ struct ArgMinMaxBase {
149149
D_ASSERT(binary.input.bind_data);
150150
const auto &bind_data = binary.input.bind_data->Cast<ArgMinMaxFunctionData>();
151151

152-
if (binary.right_mask.RowIsValid(binary.ridx) &&
153-
(state.val_null || COMPARATOR::Operation(y_data, state.value))) {
152+
if (binary.right_mask.RowIsValid(binary.ridx) && COMPARATOR::Operation(y_data, state.value)) {
154153
if (bind_data.null_handling != ArgMinMaxNullHandling::IGNORE_ANY_NULL ||
155154
binary.left_mask.RowIsValid(binary.lidx)) {
156155
Assign(state, x_data, y_data, !binary.left_mask.RowIsValid(binary.lidx), false, binary.input);

src/duckdb/extension/core_functions/aggregate/distributive/bitagg.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,13 +166,15 @@ struct BitStringBitwiseOperation : public BitwiseOperation {
166166
};
167167

168168
struct BitStringAndOperation : public BitStringBitwiseOperation {
169+
169170
template <class INPUT_TYPE, class STATE>
170171
static void Execute(STATE &state, INPUT_TYPE input) {
171172
Bit::BitwiseAnd(input, state.value, state.value);
172173
}
173174
};
174175

175176
struct BitStringOrOperation : public BitStringBitwiseOperation {
177+
176178
template <class INPUT_TYPE, class STATE>
177179
static void Execute(STATE &state, INPUT_TYPE input) {
178180
Bit::BitwiseOr(input, state.value, state.value);

src/duckdb/extension/core_functions/aggregate/distributive/bitstring_agg.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,7 @@ idx_t BitStringAggOperation::GetRange(uhugeint_t min, uhugeint_t max) {
235235

236236
unique_ptr<BaseStatistics> BitstringPropagateStats(ClientContext &context, BoundAggregateExpression &expr,
237237
AggregateStatisticsInput &input) {
238+
238239
if (NumericStats::HasMinMax(input.child_stats[0])) {
239240
auto &bind_agg_data = input.bind_data->Cast<BitstringAggBindData>();
240241
bind_agg_data.min = NumericStats::Min(input.child_stats[0]);

src/duckdb/extension/core_functions/aggregate/holistic/approximate_quantile.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -294,6 +294,7 @@ AggregateFunction GetApproximateQuantileAggregate(const LogicalType &type) {
294294

295295
template <class CHILD_TYPE>
296296
struct ApproxQuantileListOperation : public ApproxQuantileOperation {
297+
297298
template <class RESULT_TYPE, class STATE>
298299
static void Finalize(STATE &state, RESULT_TYPE &target, AggregateFinalizeData &finalize_data) {
299300
if (state.pos == 0) {

src/duckdb/extension/core_functions/aggregate/holistic/mad.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ struct QuantileReuseUpdater {
5757
};
5858

5959
void ReuseIndexes(idx_t *index, const SubFrames &currs, const SubFrames &prevs) {
60+
6061
// Copy overlapping indices by scanning the previous set and copying down into holes.
6162
// We copy instead of leaving gaps in case there are fewer values in the current frame.
6263
FrameSet prev_set(prevs);

src/duckdb/extension/core_functions/aggregate/nested/histogram.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ struct StringMapType {
6161
template <class OP, class T, class MAP_TYPE>
6262
void HistogramUpdateFunction(Vector inputs[], AggregateInputData &aggr_input, idx_t input_count, Vector &state_vector,
6363
idx_t count) {
64+
6465
D_ASSERT(input_count == 1);
6566

6667
auto &input = inputs[0];
@@ -208,6 +209,7 @@ AggregateFunction GetHistogramFunction(const LogicalType &type) {
208209
template <bool IS_ORDERED = true>
209210
unique_ptr<FunctionData> HistogramBindFunction(ClientContext &context, AggregateFunction &function,
210211
vector<unique_ptr<Expression>> &arguments) {
212+
211213
D_ASSERT(arguments.size() == 1);
212214

213215
if (arguments[0]->return_type.id() == LogicalTypeId::UNKNOWN) {

src/duckdb/extension/core_functions/aggregate/nested/list.cpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ struct ListFunction {
4747

4848
void ListUpdateFunction(Vector inputs[], AggregateInputData &aggr_input_data, idx_t input_count, Vector &state_vector,
4949
idx_t count) {
50+
5051
D_ASSERT(input_count == 1);
5152
auto &input = inputs[0];
5253
RecursiveUnifiedVectorFormat input_data;
@@ -74,6 +75,7 @@ void ListAbsorbFunction(Vector &states_vector, Vector &combined, AggregateInputD
7475

7576
auto combined_ptr = FlatVector::GetData<ListAggState *>(combined);
7677
for (idx_t i = 0; i < count; i++) {
78+
7779
auto &state = *states_ptr[states_data.sel->get_index(i)];
7880
if (state.linked_list.total_capacity == 0) {
7981
// NULL, no need to append
@@ -96,6 +98,7 @@ void ListAbsorbFunction(Vector &states_vector, Vector &combined, AggregateInputD
9698

9799
void ListFinalize(Vector &states_vector, AggregateInputData &aggr_input_data, Vector &result, idx_t count,
98100
idx_t offset) {
101+
99102
UnifiedVectorFormat states_data;
100103
states_vector.ToUnifiedFormat(count, states_data);
101104
auto states = UnifiedVectorFormat::GetData<ListAggState *>(states_data);
@@ -129,6 +132,7 @@ void ListFinalize(Vector &states_vector, AggregateInputData &aggr_input_data, Ve
129132
ListVector::Reserve(result, total_len);
130133
auto &result_child = ListVector::GetEntry(result);
131134
for (idx_t i = 0; i < count; i++) {
135+
132136
auto &state = *states[states_data.sel->get_index(i)];
133137
const auto rid = i + offset;
134138
if (state.linked_list.total_capacity == 0) {
@@ -143,6 +147,7 @@ void ListFinalize(Vector &states_vector, AggregateInputData &aggr_input_data, Ve
143147
}
144148

145149
void ListCombineFunction(Vector &states_vector, Vector &combined, AggregateInputData &aggr_input_data, idx_t count) {
150+
146151
// Can we use destructive combining?
147152
if (aggr_input_data.combine_type == AggregateCombineType::ALLOW_DESTRUCTIVE) {
148153
ListAbsorbFunction(states_vector, combined, aggr_input_data, count);
@@ -177,6 +182,7 @@ void ListCombineFunction(Vector &states_vector, Vector &combined, AggregateInput
177182

178183
unique_ptr<FunctionData> ListBindFunction(ClientContext &context, AggregateFunction &function,
179184
vector<unique_ptr<Expression>> &arguments) {
185+
180186
function.return_type = LogicalType::LIST(arguments[0]->return_type);
181187
return make_uniq<ListBindData>(function.return_type);
182188
}

src/duckdb/extension/core_functions/include/core_functions/aggregate/quantile_sort_tree.hpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,7 @@ struct QuantileIncluded {
300300
};
301301

302302
struct QuantileSortTree {
303+
303304
unique_ptr<WindowIndexTree> index_tree;
304305

305306
QuantileSortTree(AggregateInputData &aggr_input_data, const WindowPartitionInput &partition) {

src/duckdb/extension/core_functions/include/core_functions/array_kernels.hpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ struct InnerProductOp {
1313

1414
template <class TYPE>
1515
static TYPE Operation(const TYPE *lhs_data, const TYPE *rhs_data, const idx_t count) {
16+
1617
TYPE result = 0;
1718

1819
auto lhs_ptr = lhs_data;
@@ -42,6 +43,7 @@ struct CosineSimilarityOp {
4243

4344
template <class TYPE>
4445
static TYPE Operation(const TYPE *lhs_data, const TYPE *rhs_data, const idx_t count) {
46+
4547
TYPE distance = 0;
4648
TYPE norm_l = 0;
4749
TYPE norm_r = 0;
@@ -76,6 +78,7 @@ struct DistanceSquaredOp {
7678

7779
template <class TYPE>
7880
static TYPE Operation(const TYPE *lhs_data, const TYPE *rhs_data, const idx_t count) {
81+
7982
TYPE distance = 0;
8083

8184
auto l_ptr = lhs_data;

0 commit comments

Comments
 (0)