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