Skip to content

Supports UDAF and other aggregate functions not implemented#848

Merged
richox merged 17 commits intomasterfrom
dev-udaf
Feb 25, 2025
Merged

Supports UDAF and other aggregate functions not implemented#848
richox merged 17 commits intomasterfrom
dev-udaf

Conversation

@gy11233
Copy link
Contributor

@gy11233 gy11233 commented Feb 25, 2025

Which issue does this PR close?

Closes #577

Rationale for this change

Supports UDAF and aggregation functions based on DeclarativeAggregate and TypedImperativeAggregate.

What changes are included in this PR?

Are there any user-facing changes?

@gy11233 gy11233 changed the title Dev udaf Supports UDAF and other aggregate functions not implemented Feb 25, 2025
acc_idx: IdxSelection<'_>,
partial_args: &[ArrayRef],
partial_arg_idx: IdxSelection<'_>,
batch_schema: SchemaRef,
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

i suggest to create params_schema in constructor and remove this batch_schema parameter.

}
}

struct AccUnsafeRowsColumn {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

i would like a better name like AccUDAFBufferRowsColumn because it is not only for UnsafeRows.

)?)
}
AggFunction::Udaf => {
unreachable!("UDAF should be handled in create_declarative_agg")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should be create_udaf_agg

@richox richox merged commit 2c2f0a9 into master Feb 25, 2025
618 checks passed
@richox richox mentioned this pull request Apr 27, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Supports single UDAF fallback

2 participants