You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by ga...@apache.org on 2026/05/14 11:27:59 UTC
(datafusion) branch gabotechs/repartition-coalesce-batches-berfore-channels updated (675cc4b6c2 -> 503ef100cf)
This is an automated email from the ASF dual-hosted git repository.
gabotechs pushed a change to branch gabotechs/repartition-coalesce-batches-berfore-channels
in repository https://gitbox.apache.org/repos/asf/datafusion.git
from 675cc4b6c2 Remove unnecessary fetch argument
add fa9ada3687 ci: add `auto detected api change` label on breaking change detecting in the CI (#21953)
add b5c481f248 Fix fully matched row groups with null counts (#21907)
add 9aa1413e24 perf: Optimize `reverse` using bulk-NULL string builders (#21991)
add d4fb7efbbd functions: Add dict support for get field (#21115)
add ae796abe4e perf: Optimize `lower`, `upper` for ASCII inputs (#21980)
add 7d107f09ba fix(physical-plan): set column byte_size to 0 in FilterExec zero-row interval stats (#21999)
add c134a84828 Explicitly declare spill codec dependency in `physical-plan` (#21917)
add 36b1927b05 feat: Support RIGHT/FULL joins in NLJ memory-limited execution (#21833)
add fa03a4c871 feat: Improved multiple column aggregation performance by using bitmasks rather than `Vec<bool>` (#21886)
add 32f51ec655 Add benchmark_runner for sql_benchmarks with help and list commands (#22001)
add 2c7af17529 chore: `datafusion-spark` substring to support Binary types (#21979)
add 739e1471b2 Add reusable plan-time schema alignment helper and apply to RecursiveQueryExec (#21912)
add e4f43ff7af perf: Cast entire Date32 array to Date64 on 1st failure (#21948)
add cd05b41754 feat: Making From<ConfigFileDecryptionProperties/ConfigFileEncryptionProperties> conversions fallible with `TryFrom` (#21985)
add 7d63fb7e4d feat: type-keyed extensions map for PartitionedFile (#21993)
add 9488c7ab69 Upgrade to arrow-rs / parquet / avro 58.2.0 (#21812)
add 574326cc65 kill `linux-build-lib` from extended tests (#21227)
add 5c097fd7f2 chore: Rust checks are required + merge queue (#21941)
add 4c909bafc5 fix: error on CREATE EXTERNAL TABLE with no files and no explicit schema (#21965)
add 1a934d1f5e Add wide-schema benchmark suite for measuring per-file metadata overhead (#21970)
add 8a2acd09d2 chore(deps): bump ctor from 0.10.1 to 1.0.1 (#22023)
add 8d9ec685d6 ci: narrow macOS test scope to datafusion-ffi, run benchmarks on amd64 (#22048)
add 2a14a93842 fix: `median` returns Float64 for integer inputs to avoid truncation (#21988)
add f3b12166f3 fix: Correct the number of pruned/matched Parquet pages (#22031)
add d10247a2c4 fix: use datafusion_expr instead of datafusion crate (#22052)
add 60296ee2b1 chore(deps): bump github/codeql-action from 4.35.2 to 4.35.3 (#22019)
add a87f6fe8de chore(deps): bump taiki-e/install-action from 2.74.0 to 2.77.0 (#22018)
add a288e617b0 chore(deps): bump the all-other-cargo-deps group across 1 directory with 2 updates (#22022)
add cae03c9028 Allow benchmark allocator features together (#21905)
add 52f23ae8f7 fix(spark): align parse_url empty FILE path (#21969)
add 6b27d2d552 Rich t kid/introduce dict benchmarks (#21860)
add 0c38ebba11 fix: drop input plan early in `CoalescePartitionsExec` (#22017)
add 3b634aaef9 Add support for lambda column capture (#21323)
add bc6f95b2b9 fix: track join_arrays memory in reservation after SMJ spill (#21962)
add 015162afac feat: support spark compatible floor function (#21933)
add 2bf1db5b3a feat: fix NTILE distribution logic (#22051)
add ea0da8b8fc Add benchmarks for dictionary path of new_group_values (#22004)
add aca4d1377b feat: Add Protobuf support for Explain node (#21994)
add 2f29038f97 Support '0' value for parse_capacity_limit() (#22014)
add bdb1c83a74 Support `IS (NOT) DISTINCT FROM` in Unparser (#22054)
add 53517af674 perf: Use `NullBuffer::union_many` (#22070)
add e62f06c914 `vars.USE_RUNS_ON`
add 8741a7752c fix: Avoid `overlay` panic on valid Unicode input, Postgres compatibility (#22046)
add eec9e9d374 chore: Fix broken build with `--benches --all-features` (#22081)
add 3d06bedcc9 Chore: Fix TPC-DS schema/query (fixes q30 run) (#22086)
add 73ea5fd12c chore(deps): (fix CI) bump taiki-e/install-action from 2.77.0 to 2.77.6 (#22110)
add 89ac320dfd docs: add llms.txt ecosystem hub at site root (#22003)
add 7e439a254e feat: implement retract_batch for array_agg sliding window support (#22015)
add c94e75486b fix: Panic in Spark's `format_string` for illegal characters (#22077)
add 0305098d58 perf: improve Int64 `generate_series` and `range` performance (#21891)
add 526ed6c8c7 Prevent empty grouping sets from being eliminated on empty input (#22039)
add 04fbade7f2 Consolidate and document SQL AST shims (#22094)
add fe8dbfa94a Support distinct-from predicates in Parquet pruning (#22084)
add 3c5361881a fix: Incorrect behavior for `FILTER` on NULLs (#22068)
add b76970b4f9 minor: Track Parquet rows and pages matched when the page index is skipped (#22085)
add 2745cd2245 Update to `arrow` / `parquet` from 58.2.0 --> 58.3.0 (#22066)
add 631f189f0c fix: coerce operand types in Interval mul/div/intersect/union/contains (#22027)
add a1b788c01e fix(bench): avoid OOM in `array_replace` bench (#22120)
add 484bddbd95 perf: batch contiguous extend calls in `array_replace` (#22119)
add ac29ab619f Add sqllogictest coverage for unused UNNEST pruning edge cases (#22074)
add 4f896eec60 chore(deps): bump actions/labeler from 6.0.1 to 6.1.0 (#22124)
add 36aad9430f chore(deps): update maturin requirement from <2,>=1.13.1 to >=1.13.3,<2 in /docs (#22127)
add f6a19953ba fix `date_part('isodow')` (#22116)
add 44e585cbcb chore(deps): bump the all-other-cargo-deps group with 5 updates (#22128)
add 937dfdad74 chore(deps): bump github/codeql-action from 4.35.3 to 4.35.4 (#22122)
add 1f2b020888 docs: updating arrays_zip output field naming (#22133)
add fe1dd577f7 deprecate: mark Statistics V2 framework (PR #14699) as deprecated (#22071)
add fdaa32608b feat: impl Any for MemoryPool (#21803)
add 12bd5b0765 mem: Cleanup resources of done streams immediately (#22064)
add 0c4ace8b77 feat: Upgrade to sqlparser-rs 0.62.0 (#22069)
add 74c4c641f0 Propagate field metadata through NTH_VALUE, FIRST_VALUE, and LAST_VALUE window functions (#22112)
add ccc67e9a65 feat: fix windows frame positive/neg overflows (#22140)
add 7f2f78d48b feat: fix AVG sliding windows wrong results with NULLs (#22139)
add 4fac70d9b2 Minor: Disallow async function in lambdas (#22097)
add 503ef100cf Merge branch 'main' into gabotechs/repartition-coalesce-batches-berfore-channels
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 23 +
.github/workflows/audit.yml | 2 +-
.github/workflows/breaking_changes_detector.yml | 2 +-
.../breaking_changes_detector_comment.yml | 28 ++
.github/workflows/codeql.yml | 4 +-
.github/workflows/dev.yml | 2 +-
.github/workflows/extended.yml | 34 +-
.github/workflows/labeler.yml | 2 +-
.github/workflows/rust.yml | 49 +-
Cargo.lock | 208 +++++----
Cargo.toml | 24 +-
benchmarks/Cargo.toml | 4 +-
benchmarks/README.md | 53 +++
benchmarks/bench.sh | 87 ++++
benchmarks/benches/sql.rs | 9 +-
benchmarks/sql_benchmarks/README.md | 1 +
benchmarks/sql_benchmarks/tpch/tpch.suite | 16 +
.../wide_schema/benchmarks/q01.benchmark | 25 ++
.../wide_schema/benchmarks/q02.benchmark | 22 +
.../wide_schema/benchmarks/q03.benchmark | 23 +
.../wide_schema/benchmarks/q04.benchmark | 24 +
.../sql_benchmarks/wide_schema/init/cleanup.sql | 1 +
.../sql_benchmarks/wide_schema/init/load.sql | 6 +
benchmarks/src/benchmark_runner/cli.rs | 81 ++++
benchmarks/src/benchmark_runner/mod.rs | 104 +++++
benchmarks/src/benchmark_runner/output.rs | 173 +++++++
benchmarks/src/benchmark_runner/suite.rs | 500 +++++++++++++++++++++
.../src/bin/benchmark_runner.rs | 19 +-
benchmarks/src/bin/dfbench.rs | 15 +-
benchmarks/src/bin/gen_wide_data.rs | 351 +++++++++++++++
benchmarks/src/bin/imdb.rs | 9 +-
benchmarks/src/dict.rs | 436 ++++++++++++++++++
benchmarks/src/lib.rs | 2 +
datafusion-cli/Cargo.toml | 6 +-
datafusion-cli/tests/cli_integration.rs | 2 +-
datafusion-examples/Cargo.toml | 2 +-
.../examples/data_io/parquet_advanced_index.rs | 2 +-
datafusion/catalog-listing/src/options.rs | 31 +-
datafusion/common/src/config.rs | 207 +++++++--
datafusion/common/src/extensions.rs | 211 +++++++++
datafusion/common/src/lib.rs | 1 +
datafusion/common/src/utils/mod.rs | 157 ++++++-
datafusion/core/Cargo.toml | 2 +-
.../core/src/datasource/listing_table_factory.rs | 12 +-
.../core/src/datasource/physical_plan/parquet.rs | 67 +++
datafusion/core/src/execution/context/mod.rs | 6 +-
datafusion/core/src/execution/context/parquet.rs | 41 +-
datafusion/core/tests/core_integration.rs | 2 +-
datafusion/core/tests/dataframe/describe.rs | 2 +-
datafusion/core/tests/dataframe/mod.rs | 40 +-
datafusion/core/tests/fuzz.rs | 2 +-
datafusion/core/tests/memory_limit/mod.rs | 2 +-
datafusion/core/tests/optimizer/mod.rs | 2 +-
datafusion/core/tests/parquet/custom_reader.rs | 86 +++-
.../core/tests/parquet/external_access_plan.rs | 2 +-
datafusion/core/tests/parquet/mod.rs | 2 +-
datafusion/core/tests/parquet/row_group_pruning.rs | 75 ++++
.../physical_optimizer/partition_statistics.rs | 11 +-
datafusion/core/tests/sql/aggregates/dict_nulls.rs | 28 +-
datafusion/core/tests/sql/explain_analyze.rs | 2 +-
datafusion/core/tests/tpc-ds/30.sql | 5 +-
datafusion/core/tests/user_defined_integration.rs | 2 +-
datafusion/datasource-parquet/src/file_format.rs | 4 +-
datafusion/datasource-parquet/src/opener.rs | 30 +-
datafusion/datasource-parquet/src/page_filter.rs | 41 +-
.../datasource-parquet/src/row_group_filter.rs | 108 ++++-
datafusion/datasource-parquet/src/source.rs | 5 +-
datafusion/datasource/src/mod.rs | 58 ++-
datafusion/execution/src/config.rs | 61 +--
datafusion/execution/src/memory_pool/mod.rs | 27 +-
datafusion/execution/src/runtime_env.rs | 8 +-
datafusion/expr-common/src/interval_arithmetic.rs | 348 ++++++++++----
datafusion/expr-common/src/operator.rs | 6 +-
datafusion/expr-common/src/statistics.rs | 62 +++
datafusion/expr/src/execution_props.rs | 24 +-
datafusion/expr/src/expr.rs | 127 +-----
datafusion/expr/src/higher_order_function.rs | 125 +++++-
datafusion/expr/src/lib.rs | 4 +-
datafusion/expr/src/logical_plan/ddl.rs | 4 +-
datafusion/expr/src/sql.rs | 174 +++++++
datafusion/expr/src/utils.rs | 33 +-
datafusion/expr/src/window_state.rs | 57 ++-
datafusion/ffi/src/expr/distribution.rs | 7 +
datafusion/ffi/src/physical_expr/mod.rs | 7 +
.../src/aggregate/groups_accumulator/accumulate.rs | 114 +++--
.../src/aggregate/groups_accumulator/nulls.rs | 27 +-
datafusion/functions-aggregate/src/array_agg.rs | 389 +++++++++++++++-
datafusion/functions-aggregate/src/average.rs | 50 ++-
datafusion/functions-aggregate/src/median.rs | 25 +-
datafusion/functions-nested/Cargo.toml | 8 +
.../functions-nested/benches/array_expression.rs | 17 +-
datafusion/functions-nested/benches/array_range.rs | 208 +++++++++
.../benches/{array_remove.rs => array_replace.rs} | 256 ++++++-----
datafusion/functions-nested/src/array_any_match.rs | 10 +-
datafusion/functions-nested/src/array_transform.rs | 12 +-
datafusion/functions-nested/src/extract.rs | 6 +-
datafusion/functions-nested/src/range.rs | 87 ++--
datafusion/functions-nested/src/replace.rs | 34 +-
datafusion/functions-window/src/nth_value.rs | 24 +-
datafusion/functions-window/src/ntile.rs | 47 +-
datafusion/functions/Cargo.toml | 4 +
.../space.rs => functions/benches/overlay.rs} | 51 +--
datafusion/functions/src/core/getfield.rs | 185 +++++++-
datafusion/functions/src/core/overlay.rs | 241 +++++-----
datafusion/functions/src/datetime/date_part.rs | 15 +-
datafusion/functions/src/datetime/make_time.rs | 7 +-
datafusion/functions/src/datetime/to_char.rs | 40 +-
datafusion/functions/src/lib.rs | 2 +-
datafusion/functions/src/string/common.rs | 227 ++++++++--
datafusion/functions/src/string/lower.rs | 140 ++++++
datafusion/functions/src/string/replace.rs | 14 +-
datafusion/functions/src/string/upper.rs | 181 +++++++-
datafusion/functions/src/strings.rs | 25 +-
datafusion/functions/src/unicode/reverse.rs | 137 ++++--
datafusion/functions/src/unicode/substr.rs | 21 +-
datafusion/functions/src/unicode/substrindex.rs | 14 +-
datafusion/optimizer/src/lib.rs | 2 +-
.../optimizer/src/propagate_empty_relation.rs | 32 +-
.../optimizer/tests/optimizer_integration.rs | 2 +-
.../physical-expr-common/src/physical_expr.rs | 11 +
datafusion/physical-expr/src/expressions/binary.rs | 7 +
datafusion/physical-expr/src/expressions/case.rs | 59 ++-
datafusion/physical-expr/src/expressions/column.rs | 1 +
datafusion/physical-expr/src/expressions/lambda.rs | 106 ++++-
.../src/expressions/lambda_variable.rs | 3 +-
.../physical-expr/src/expressions/negative.rs | 4 +
datafusion/physical-expr/src/expressions/not.rs | 4 +
.../physical-expr/src/higher_order_function.rs | 22 +-
datafusion/physical-expr/src/planner.rs | 69 ++-
datafusion/physical-expr/src/statistics/mod.rs | 5 +-
.../physical-expr/src/statistics/stats_solver.rs | 15 +
datafusion/physical-plan/Cargo.toml | 8 +
.../physical-plan/benches/aggregate_vectorized.rs | 16 +-
.../benches/dictionary_group_values.rs | 176 ++++++++
.../group_values/multi_group_by/boolean.rs | 194 ++++----
.../group_values/multi_group_by/bytes.rs | 134 +++---
.../group_values/multi_group_by/bytes_view.rs | 153 ++++---
.../aggregates/group_values/multi_group_by/mod.rs | 41 +-
.../group_values/multi_group_by/primitive.rs | 256 ++++++-----
datafusion/physical-plan/src/aggregates/mod.rs | 9 +-
.../physical-plan/src/aggregates/no_grouping.rs | 4 +
.../physical-plan/src/aggregates/row_hash.rs | 114 ++++-
.../physical-plan/src/aggregates/topk_stream.rs | 4 +
datafusion/physical-plan/src/analyze.rs | 1 +
datafusion/physical-plan/src/async_func.rs | 6 +-
datafusion/physical-plan/src/coalesce_batches.rs | 6 +
.../physical-plan/src/coalesce_partitions.rs | 44 +-
datafusion/physical-plan/src/common.rs | 258 ++++++++++-
datafusion/physical-plan/src/filter.rs | 14 +-
datafusion/physical-plan/src/joins/cross_join.rs | 8 +-
.../physical-plan/src/joins/hash_join/stream.rs | 6 +
.../physical-plan/src/joins/nested_loop_join.rs | 469 ++++++++++++++++---
.../src/joins/piecewise_merge_join/classic_join.rs | 4 +
.../src/joins/sort_merge_join/bitwise_stream.rs | 16 +-
.../joins/sort_merge_join/materializing_stream.rs | 66 ++-
.../src/joins/sort_merge_join/tests.rs | 217 +++++++++
.../physical-plan/src/joins/symmetric_hash_join.rs | 18 +
.../physical-plan/src/operator_statistics/mod.rs | 21 +-
datafusion/physical-plan/src/recursive_query.rs | 101 ++++-
datafusion/physical-plan/src/repartition/mod.rs | 8 +-
datafusion/physical-plan/src/sorts/partial_sort.rs | 7 +
.../physical-plan/src/sorts/partitioned_topk.rs | 2 +
datafusion/physical-plan/src/sorts/sort.rs | 2 +
datafusion/physical-plan/src/spill/mod.rs | 17 +-
.../src/spill/replayable_spill_input.rs | 3 +
datafusion/physical-plan/src/stream.rs | 74 ++-
datafusion/physical-plan/src/unnest.rs | 10 +
.../src/windows/bounded_window_agg_exec.rs | 5 +
.../physical-plan/src/windows/window_agg_exec.rs | 5 +
.../proto-common/proto/datafusion_common.proto | 7 +
datafusion/proto-common/src/generated/pbjson.rs | 77 ++++
datafusion/proto-common/src/generated/prost.rs | 32 ++
datafusion/proto/proto/datafusion.proto | 1 +
.../proto/src/generated/datafusion_proto_common.rs | 32 ++
datafusion/proto/src/generated/pbjson.rs | 19 +
datafusion/proto/src/generated/prost.rs | 2 +
datafusion/proto/src/logical_plan/mod.rs | 31 +-
.../proto/tests/cases/roundtrip_logical_plan.rs | 22 +
datafusion/pruning/src/pruning_predicate.rs | 289 ++++++++++--
datafusion/spark/Cargo.toml | 4 +
datafusion/spark/benches/{sha2.rs => floor.rs} | 92 ++--
datafusion/spark/src/function/array/repeat.rs | 2 +-
.../spark/src/function/datetime/date_part.rs | 7 +-
datafusion/spark/src/function/map/str_to_map.rs | 15 +-
datafusion/spark/src/function/math/floor.rs | 182 ++++++++
datafusion/spark/src/function/math/mod.rs | 4 +
datafusion/spark/src/function/null_utils.rs | 80 ++--
datafusion/spark/src/function/string/concat.rs | 2 +-
.../spark/src/function/string/format_string.rs | 166 ++++++-
.../spark/src/function/string/is_valid_utf8.rs | 6 +-
datafusion/spark/src/function/string/substring.rs | 231 ++++++++--
datafusion/spark/src/function/url/parse_url.rs | 129 +++++-
datafusion/sql/src/expr/function.rs | 15 +-
datafusion/sql/src/expr/mod.rs | 8 +-
datafusion/sql/src/query.rs | 1 +
datafusion/sql/src/select.rs | 6 +
datafusion/sql/src/statement.rs | 116 ++++-
datafusion/sql/src/unparser/ast.rs | 6 +-
datafusion/sql/src/unparser/expr.rs | 59 ++-
datafusion/sql/src/unparser/plan.rs | 3 +
datafusion/sql/src/values.rs | 3 +-
datafusion/sql/tests/sql_integration.rs | 2 +-
datafusion/sqllogictest/Cargo.toml | 6 +-
datafusion/sqllogictest/src/test_context.rs | 103 ++++-
datafusion/sqllogictest/test_files/aggregate.slt | 146 +++---
.../test_files/aggregate_skip_partial.slt | 22 +-
.../sqllogictest/test_files/array/array_range.slt | 10 +
.../test_files/array/array_replace.slt | 16 +-
.../test_files/array/array_transform.slt | 192 +++++++-
.../test_files/array_agg_sliding_window.slt | 185 ++++++++
datafusion/sqllogictest/test_files/async_udf.slt | 10 +
.../test_files/clickbench_extended.slt | 2 +-
datafusion/sqllogictest/test_files/cte.slt | 6 +-
.../sqllogictest/test_files/datetime/date_part.slt | 8 +-
datafusion/sqllogictest/test_files/ddl.slt | 41 ++
datafusion/sqllogictest/test_files/decimal.slt | 25 ++
.../sqllogictest/test_files/dictionary_struct.slt | 154 +++++++
.../sqllogictest/test_files/explain_analyze.slt | 6 +-
datafusion/sqllogictest/test_files/functions.slt | 87 +++-
datafusion/sqllogictest/test_files/grouping.slt | 31 ++
.../sqllogictest/test_files/information_schema.slt | 8 +-
.../sqllogictest/test_files/limit_pruning.slt | 4 +-
datafusion/sqllogictest/test_files/metadata.slt | 46 ++
.../test_files/nested_loop_join_spill.slt | 71 +++
.../sqllogictest/test_files/set_variable.slt | 9 +
.../sqllogictest/test_files/spark/math/floor.slt | 304 +++++++++++--
.../test_files/spark/string/format_string.slt | 4 +
.../test_files/spark/string/substring.slt | 162 ++++++-
.../test_files/spark/url/parse_url.slt | 80 ++++
.../test_files/spark/url/try_parse_url.slt | 80 ++++
.../test_files/string/string_query.slt.part | 4 +-
datafusion/sqllogictest/test_files/unnest.slt | 85 ++++
datafusion/sqllogictest/test_files/window.slt | 333 ++++++++++++++
dev/release/generate-changelog.py | 2 +-
dev/release/rat_exclude_files.txt | 1 +
docs/pyproject.toml | 2 +-
docs/source/conf.py | 4 +
docs/source/library-user-guide/upgrading/54.0.0.md | 152 +++++++
docs/source/llms.txt | 26 ++
docs/source/user-guide/configs.md | 16 +-
docs/source/user-guide/sql/scalar_functions.md | 2 +-
test-utils/src/tpcds.rs | 2 +-
242 files changed, 12050 insertions(+), 2174 deletions(-)
create mode 100644 benchmarks/sql_benchmarks/tpch/tpch.suite
create mode 100644 benchmarks/sql_benchmarks/wide_schema/benchmarks/q01.benchmark
create mode 100644 benchmarks/sql_benchmarks/wide_schema/benchmarks/q02.benchmark
create mode 100644 benchmarks/sql_benchmarks/wide_schema/benchmarks/q03.benchmark
create mode 100644 benchmarks/sql_benchmarks/wide_schema/benchmarks/q04.benchmark
create mode 100644 benchmarks/sql_benchmarks/wide_schema/init/cleanup.sql
create mode 100644 benchmarks/sql_benchmarks/wide_schema/init/load.sql
create mode 100644 benchmarks/src/benchmark_runner/cli.rs
create mode 100644 benchmarks/src/benchmark_runner/mod.rs
create mode 100644 benchmarks/src/benchmark_runner/output.rs
create mode 100644 benchmarks/src/benchmark_runner/suite.rs
copy datafusion/core/src/bin/print_runtime_config_docs.rs => benchmarks/src/bin/benchmark_runner.rs (58%)
create mode 100644 benchmarks/src/bin/gen_wide_data.rs
create mode 100644 benchmarks/src/dict.rs
create mode 100644 datafusion/common/src/extensions.rs
create mode 100644 datafusion/expr/src/sql.rs
create mode 100644 datafusion/functions-nested/benches/array_range.rs
copy datafusion/functions-nested/benches/{array_remove.rs => array_replace.rs} (69%)
copy datafusion/{spark/benches/space.rs => functions/benches/overlay.rs} (65%)
create mode 100644 datafusion/physical-plan/benches/dictionary_group_values.rs
copy datafusion/spark/benches/{sha2.rs => floor.rs} (54%)
create mode 100644 datafusion/spark/src/function/math/floor.rs
create mode 100644 datafusion/sqllogictest/test_files/array_agg_sliding_window.slt
create mode 100644 datafusion/sqllogictest/test_files/dictionary_struct.slt
create mode 100644 docs/source/llms.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org