Skip to content

Introduce Async User Defined Functions #14837

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
alamb merged 20 commits into from
Jun 23, 2025
Merged

Introduce Async User Defined Functions #14837

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
65c99af
introduce async udf for projection
goldmedal Feb 23, 2025
0902e8e
refactor for filter
goldmedal Feb 23, 2025
ca00e72
coalesce_batches for AsyncFuncExec
goldmedal Feb 23, 2025
e06e4bb
project filter to exclude the filter expression
goldmedal Feb 23, 2025
f09337f
coalesce the input batch of AsyncFuncExec
goldmedal Feb 23, 2025
fe12d72
simple example
goldmedal Feb 23, 2025
875d4e5
enhance comment
goldmedal Feb 23, 2025
017b111
enhance doc and fix test
goldmedal Feb 23, 2025
da065ef
fix clippy and fmt
goldmedal Mar 11, 2025
3a2e7ff
add missing dependency
goldmedal Mar 11, 2025
cce1586
fix clippy
goldmedal Mar 11, 2025
5fbdd04
rename the symbol
goldmedal Mar 22, 2025
92e8144
cargo fmt
goldmedal Mar 22, 2025
ea0ce98
fix fmt and rebase
goldmedal Mar 22, 2025
4d4145b
add return_field_from_args for async scalar udf
goldmedal May 18, 2025
68b2203
modified into_scalar_udf method
goldmedal May 18, 2025
6f05ec3
add the async scalar udf in udfs doc
goldmedal May 18, 2025
68debd5
pretty doc
goldmedal May 18, 2025
98cf8e2
fix doc test
goldmedal May 18, 2025
5f55674
fix merge conflict
goldmedal Jun 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
enhance comment
  • Loading branch information
@goldmedal
goldmedal committed Jun 23, 2025
commit 875d4e5083f6be6f2b9008f8770110676dfbe788
1 change: 1 addition & 0 deletions datafusion-examples/examples/async_udf.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,7 @@ async fn main() -> Result<()> {
.show()
.await?;

// use Async UDF in the filter
// +---------------+--------------------------------------------------------------------------------------------+
// | plan_type | plan |
// +---------------+--------------------------------------------------------------------------------------------+
Expand Down