You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by al...@apache.org on 2023/06/22 17:08:19 UTC
[arrow-datafusion] branch main updated (eb290a0bb9 -> b1b8c9caa2)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from eb290a0bb9 Update documentation for creating User Defined Aggregates (AggregateUDF) (#6729)
add b1b8c9caa2 Support User Defined Window Functions (#6703)
No new revisions were added by this update.
Summary of changes:
datafusion-examples/Cargo.toml | 1 +
datafusion-examples/README.md | 1 +
datafusion-examples/examples/rewrite_expr.rs | 6 +-
datafusion-examples/examples/simple_udwf.rs | 211 ++++++++
datafusion/core/src/dataframe.rs | 8 +
datafusion/core/src/execution/context.rs | 43 +-
datafusion/core/src/physical_plan/windows/mod.rs | 75 ++-
datafusion/core/tests/data/cars.csv | 26 +
.../sqllogictests/src/engines/datafusion/util.rs | 6 +-
.../sorts => tests/user_defined}/mod.rs | 16 +-
.../{ => user_defined}/user_defined_aggregates.rs | 0
.../tests/{ => user_defined}/user_defined_plan.rs | 0
.../user_defined/user_defined_window_functions.rs | 548 +++++++++++++++++++++
.../tests/{fuzz.rs => user_defined_integration.rs} | 4 +-
datafusion/execution/src/registry.rs | 5 +-
datafusion/execution/src/task.rs | 25 +-
datafusion/expr/src/expr_fn.rs | 23 +
datafusion/expr/src/function.rs | 7 +-
datafusion/expr/src/lib.rs | 6 +-
datafusion/expr/src/partition_evaluator.rs | 16 +-
datafusion/expr/src/udaf.rs | 6 +-
datafusion/expr/src/udwf.rs | 118 +++++
datafusion/expr/src/window_function.rs | 17 +-
.../optimizer/tests/optimizer_integration.rs | 6 +-
datafusion/proto/src/bytes/mod.rs | 17 +-
datafusion/proto/src/bytes/registry.rs | 8 +-
datafusion/proto/src/logical_plan/to_proto.rs | 6 +
datafusion/sql/examples/sql.rs | 5 +
datafusion/sql/src/expr/function.rs | 7 +
datafusion/sql/src/expr/mod.rs | 6 +-
datafusion/sql/src/planner.rs | 3 +
datafusion/sql/tests/sql_integration.rs | 6 +-
32 files changed, 1189 insertions(+), 43 deletions(-)
create mode 100644 datafusion-examples/examples/simple_udwf.rs
create mode 100644 datafusion/core/tests/data/cars.csv
copy datafusion/core/{src/physical_plan/sorts => tests/user_defined}/mod.rs (79%)
rename datafusion/core/tests/{ => user_defined}/user_defined_aggregates.rs (100%)
rename datafusion/core/tests/{ => user_defined}/user_defined_plan.rs (100%)
create mode 100644 datafusion/core/tests/user_defined/user_defined_window_functions.rs
copy datafusion/core/tests/{fuzz.rs => user_defined_integration.rs} (91%)
create mode 100644 datafusion/expr/src/udwf.rs