This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch dependabot/cargo/main/proto-33bc8ff79f
in repository https://gitbox.apache.org/repos/asf/datafusion.git
omit ad9a9a0444 chore(deps): bump pbjson-types in the proto group across 1
directory
add 24be188b7f Align DataFrame::fill_null column argument with fill_nan
(#22904)
add d09a52af28 Add regression tests for hash-join dynamic filter
expression policy (#23319)
add 70276ac57c chore: update crossbeam-epoch to 0.9.20 (#23358)
add 9747084187 chore(docs): resolve some docs typos (#23347)
add 35a95f26cd v54 upgrade guide: Remove unreleased-note (#23331)
add 34274f32df IN LIST: add Float16 bitmap filter (#23311)
add fb884571ce feat: support decimals in trunc UDF (#23320)
add 66fdcb01cb feat: add strictness metadata for scalar UDF null
propagation and use it in outer join elimination (#23148)
add 7ff7278edc fix: Reject out-of-range `ArrayMap` probe keys on 32-bit
targets (#22911)
add c7f0515a20 chore(deps): bump astral-sh/setup-uv from 8.2.0 to 8.3.1
(#23366)
add d84e214131 chore(deps): bump taiki-e/install-action from 2.82.6 to
2.82.10 (#23365)
add 67ff4e4f7a chore(deps): bump actions/checkout from 6.0.3 to 7.0.0
(#23367)
add 99ccfc3c16 minor: rename aggregate stream modules to match contents
(#23372)
add c2e347370a test: cover float IN list predicates (#23373)
add 24a7300e96 docs: document ClickBench setup details (#23315)
add e5cdf2079c docs: add DataFusion Ballista to related subproject (#23377)
add 1ca0073cc2 chore(deps): update setuptools requirement from
<83,>=82.0.1 to >=83.0.0,<84 in /docs (#23361)
add 8272b4aa20 fix: return execution error instead of capacity overflow
panic in array_resize (#23306)
add 55292fb623 fix: cardinality returns incorrect results for ragged
nested arrays (#23271)
add e65b3f378c test: Add coverage for `NOT IN` predicates (#23378)
add a58dfc605a chore(deps): bump runs-on/action from 2.1.2 to 2.2.0
(#23363)
add f34a676302 chore: Update to arrow/parquet 59.1.0 (#23312)
add b386413603 Fix:22477 any all schema error (#22915)
add 294563186c [codex] chore: update Rust toolchain to 1.96.1 (#23379)
add 3089ace491 perf: preserve dictionary encoding for lower/upper to avoid
materializing low-cardinality columns (#22905)
add 9dc0f4b50c fix: cast `[]` to `FixedSizeList(0, _)` (#23381)
add 50dcf0f47a feat: physical execution for range partitioning (#23231)
add 8139397c8a Push sort requirements through simple projections (#23288)
add 4ca85d20fe refactor(hash-aggr): Simplify aggregate hash table with
tempated functions (#23324)
add b790763529 refactor: centralizing shared-allocation accounting for Arc
DFHeapSize impls (#23349)
add 215ebb8471 Fix union equivalence schema rewrite with stale constants
(#23375)
add cd47b95508 feat: Support FixedSizedBinary type for approx_distinct
(#23417)
add 059be71a50 docs: add infino to known users (#23383)
add 73d5d7803b Fix memory size accounting for grouped `median` and `avg`
(#23357)
add 4f63ada240 chore(spm): extract initialize all parititions helper
(#23419)
add d213a8adf2 refactor: extract parquet projection read plan into its own
module (#23396)
add e1b773a29f Remove unstable public methods for
`DynamicFilterPhysicalExpr` after proto migration (#23423)
add 2880e1044c Perf: Add short circuit for primitive vectorized equal_to
(#23343)
add 0977bb3819 refactor: centralize date_bin per-row mapping (#23034)
add 66b059e041 refactor: remove redundant partitioned_by_file_group file
scan field (#23189)
add 1c1a78a0a4 chore: cleanup some TODO items in sqllogictests (#23382)
add 1dc73dcf6a bench: add date_part benchmark (#23350)
add 4207291552 Update Rust toolchain to 1.97.0 (#23430)
add b9968a06ea refactor: de-duplicate parquet read plan construction
(#23426)
add f4a700d79d chore(deps): bump soupsieve from 2.8.3 to 2.8.4 (#23432)
add 1e77af86a3 fix: don't duplicate volatile expressions when pushing
projection into file scan (#23395)
add b79d3965b7 Use `concat_elements_dyn` from `arrow-rs` (#23211)
add 7ac784f9ea Add protobuf support for lambdas (#22362)
add 24d8957cf4 perf(physical-plan): fold PlanProperties fast-path into
with_new_children_if_necessary (PR 1 of #22555) (#23332)
add 63e25c15bc Support co-partitioned range inner equi joins (#23184)
add 844c62e55f Minor: Fix docs for JoinSet (#23448)
add 4f3980210c fix: fix typo on doc (#23457)
add f269b94bc2 test: add Poll::Pending spill stream coverage for async
spill re-entry paths (#23353)
add 3e058f09c9 feat: Implement state conversion for remaining group
accumulators (#23275)
add 5b60fcb110 perf: optimize encode in datafusion-functions (#23456)
add fa40708411 perf: optimize ascii in datafusion-functions (#23462)
add 479a0aa96d perf: optimize nanvl in datafusion-functions (#23458)
add 95398f07f2 Test: add more aggregation focused dictionary sql logic
test (#23280)
add c70a053ee2 minor: Remove `.gitignore` item for datafusion-examples
(#23409)
add a29c58f105 minor: remove local file commited by mistake (#23476)
add 2fbc758263 perf: avoid intermediate slice allocation in Spark slice
function (#23481)
add 9ec28bda1f bench: add sort benchmarks for various data profile (#23346)
add cf479db6c3 feat: Support List/ListView types in approx_distinct
(#23443)
add 5e80f6cda3 refactor(hash-aggr): Migrate single mode hash aggregation
(#23408)
add 761f7f6918 test: add sqllogictest coverage for DISTINCT / GROUP BY /
aggregation on map columns (#23406)
add 360a56dfe4 refactor: Migrate ScalarSubqueryExpr to self-serialization
proto pattern (#23130)
add f87e8174c1 perf: optimize make_date in datafusion-functions (#23470)
add 13a6e3003f chore: use new `OffsetBuffer::subtract` helper (#23424)
add 36d1c98f22 feat: add array_first higher-order array function (#23267)
add 34c4849038 Decode Hive partition values in listing tables (#23226)
add 05bcf5591d chore(deps): bump pbjson-types in the proto group across 1
directory
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ad9a9a0444)
\
N -- N -- N refs/heads/dependabot/cargo/main/proto-33bc8ff79f
(05bcf5591d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/audit.yml | 2 +-
.github/workflows/breaking_changes_detector.yml | 2 +-
.github/workflows/dev.yml | 2 +-
.github/workflows/docs.yaml | 2 +-
.github/workflows/docs_pr.yaml | 2 +-
.github/workflows/extended.yml | 6 +-
.github/workflows/rust.yml | 34 +-
.gitignore | 3 -
Cargo.lock | 77 +-
Cargo.toml | 19 +-
README.md | 2 +
benchmarks/README.md | 43 +
benchmarks/src/imdb/convert.rs | 2 +-
.../examples/external_dependency/query_aws_s3.rs | 2 +-
datafusion-examples/examples/flight/server.rs | 4 +-
datafusion-examples/examples/udf/advanced_udaf.rs | 43 +-
datafusion/catalog-listing/Cargo.toml | 1 +
datafusion/catalog-listing/src/helpers.rs | 130 ++-
datafusion/catalog-listing/src/table.rs | 38 +-
datafusion/common-runtime/src/join_set.rs | 7 +-
datafusion/common/src/column.rs | 2 +-
datafusion/common/src/config.rs | 2 +-
datafusion/common/src/error.rs | 9 +-
datafusion/common/src/heap_size.rs | 28 +-
datafusion/common/src/scalar/mod.rs | 13 +-
datafusion/common/src/utils/mod.rs | 18 +-
datafusion/core/benches/sort.rs | 332 +++++-
datafusion/core/src/dataframe/mod.rs | 15 +-
datafusion/core/src/datasource/file_format/csv.rs | 2 +-
datafusion/core/src/datasource/file_format/json.rs | 2 +-
datafusion/core/src/datasource/listing/table.rs | 2 +-
datafusion/core/src/execution/context/mod.rs | 4 +-
datafusion/core/tests/core_integration.rs | 3 +
datafusion/core/tests/dataframe/mod.rs | 44 +-
datafusion/core/tests/fuzz_cases/join_fuzz.rs | 10 +-
.../core/tests/{datasource => helper}/mod.rs | 11 +-
datafusion/core/tests/helper/plan_metrics.rs | 54 +
datafusion/core/tests/memory_limit/mod.rs | 20 +-
.../physical_optimizer/enforce_distribution.rs | 115 +-
.../tests/physical_optimizer/enforce_sorting.rs | 238 +++++
.../physical_optimizer/ensure_requirements.rs | 16 +-
.../physical_optimizer/projection_pushdown.rs | 4 +-
.../tests/physical_optimizer/sanity_checker.rs | 51 +-
datafusion/core/tests/sql/explain_analyze.rs | 4 +-
datafusion/core/tests/sql/runtime_config.rs | 8 +-
.../tests/user_defined/user_defined_aggregates.rs | 16 +
.../core/tests/user_defined/user_defined_plan.rs | 8 +-
datafusion/datasource-arrow/src/file_format.rs | 4 +-
datafusion/datasource-csv/src/file_format.rs | 4 +-
datafusion/datasource-json/src/file_format.rs | 2 +-
.../datasource-parquet/src/decoder_projection.rs | 2 +-
datafusion/datasource-parquet/src/mod.rs | 1 +
datafusion/datasource-parquet/src/page_filter.rs | 2 +-
.../datasource-parquet/src/projection_read_plan.rs | 758 ++++++++++++++
datafusion/datasource-parquet/src/row_filter.rs | 744 +------------
datafusion/datasource/src/file_scan_config/mod.rs | 301 +++++-
datafusion/datasource/src/file_stream/mod.rs | 32 +-
datafusion/datasource/src/sink.rs | 14 +-
datafusion/execution/src/config.rs | 2 +-
datafusion/execution/src/memory_pool/pool.rs | 12 +-
datafusion/expr-common/src/signature.rs | 85 +-
datafusion/expr-common/src/type_coercion/binary.rs | 101 +-
.../src/type_coercion/binary/tests/comparison.rs | 3 +-
.../src/type_coercion/binary/tests/mod.rs | 10 +-
datafusion/expr/src/lib.rs | 4 +-
datafusion/expr/src/logical_plan/display.rs | 6 +-
datafusion/expr/src/logical_plan/plan.rs | 3 +-
datafusion/expr/src/predicate_bounds.rs | 79 +-
datafusion/expr/src/sql.rs | 2 +-
datafusion/expr/src/type_coercion/functions.rs | 166 ++-
datafusion/expr/src/udf.rs | 26 +
.../src/aggregate/count_distinct/groups.rs | 121 ++-
.../functions-aggregate/src/approx_distinct.rs | 141 +++
datafusion/functions-aggregate/src/average.rs | 9 +-
datafusion/functions-aggregate/src/correlation.rs | 141 +++
datafusion/functions-aggregate/src/median.rs | 7 +-
.../src/min_max/min_max_struct.rs | 2 +-
datafusion/functions-aggregate/src/stddev.rs | 16 +-
datafusion/functions-aggregate/src/variance.rs | 123 +++
datafusion/functions-nested/src/array_compact.rs | 4 +-
datafusion/functions-nested/src/array_first.rs | 441 ++++++++
datafusion/functions-nested/src/arrays_zip.rs | 6 +-
datafusion/functions-nested/src/cardinality.rs | 59 +-
datafusion/functions-nested/src/concat.rs | 10 +-
datafusion/functions-nested/src/extract.rs | 24 +-
datafusion/functions-nested/src/lib.rs | 3 +
datafusion/functions-nested/src/make_array.rs | 4 +-
datafusion/functions-nested/src/map_extract.rs | 4 +-
datafusion/functions-nested/src/remove.rs | 12 +-
datafusion/functions-nested/src/replace.rs | 30 +-
datafusion/functions-nested/src/resize.rs | 110 +-
datafusion/functions-nested/src/sort.rs | 7 +-
datafusion/functions/Cargo.toml | 5 +
datafusion/functions/benches/date_part.rs | 349 +++++++
datafusion/functions/benches/encoding.rs | 25 +
datafusion/functions/benches/nanvl.rs | 74 ++
datafusion/functions/src/core/getfield.rs | 8 +-
datafusion/functions/src/datetime/date_bin.rs | 396 ++++---
datafusion/functions/src/datetime/make_date.rs | 102 +-
datafusion/functions/src/encoding/inner.rs | 45 +-
datafusion/functions/src/math/abs.rs | 4 +
datafusion/functions/src/math/nanvl.rs | 203 +++-
datafusion/functions/src/math/trunc.rs | 260 ++++-
datafusion/functions/src/string/ascii.rs | 57 +-
datafusion/functions/src/string/common.rs | 162 +--
datafusion/functions/src/string/lower.rs | 11 +-
datafusion/functions/src/string/split_part.rs | 12 +-
datafusion/functions/src/string/upper.rs | 11 +-
datafusion/functions/src/unicode/initcap.rs | 17 +-
datafusion/functions/src/utils.rs | 3 +-
datafusion/optimizer/src/eliminate_outer_join.rs | 161 ++-
.../optimizer/src/optimize_projections/mod.rs | 70 +-
.../optimizer/src/simplify_expressions/regex.rs | 23 +-
.../src/simplify_expressions/simplify_literal.rs | 2 +-
datafusion/physical-expr-common/src/utils.rs | 10 +-
.../physical-expr/benches/in_list_strategy.rs | 20 +-
.../src/equivalence/properties/joins.rs | 2 +-
.../src/equivalence/properties/mod.rs | 13 +-
.../src/equivalence/properties/union.rs | 32 +-
datafusion/physical-expr/src/expressions/binary.rs | 43 +-
.../src/expressions/binary/kernels.rs | 89 --
.../src/expressions/dynamic_filters/mod.rs | 63 +-
.../physical-expr/src/expressions/in_list.rs | 1 +
.../src/expressions/in_list/primitive_filter.rs | 54 +-
.../src/expressions/in_list/strategy.rs | 7 +-
datafusion/physical-expr/src/expressions/lambda.rs | 39 +
.../src/expressions/lambda_variable.rs | 44 +
datafusion/physical-expr/src/expressions/mod.rs | 1 -
datafusion/physical-expr/src/lib.rs | 4 +-
datafusion/physical-expr/src/partitioning.rs | 248 +----
datafusion/physical-expr/src/physical_expr.rs | 19 +-
datafusion/physical-expr/src/scalar_subquery.rs | 203 +++-
.../ensure_requirements/enforce_distribution.rs | 314 ++++--
.../src/ensure_requirements/enforce_sorting/mod.rs | 22 +-
.../enforce_sorting/sort_pushdown.rs | 83 +-
.../src/limited_distinct_aggregation.rs | 5 +-
.../physical-optimizer/src/output_requirements.rs | 33 +-
.../physical-optimizer/src/sanity_checker.rs | 49 +-
datafusion/physical-optimizer/src/utils.rs | 19 -
.../src/aggregates/aggregate_hash_table/common.rs | 125 ++-
.../aggregate_hash_table/common_ordered.rs | 2 +-
.../aggregates/aggregate_hash_table/final_table.rs | 92 +-
.../src/aggregates/aggregate_hash_table/mod.rs | 3 +-
.../aggregate_hash_table/partial_reduce_table.rs | 93 +-
.../aggregate_hash_table/partial_table.rs | 85 +-
.../aggregate_hash_table/single_table.rs | 74 ++
.../{no_grouping.rs => aggregate_stream.rs} | 0
.../group_values/multi_group_by/primitive.rs | 28 +-
.../{row_hash.rs => grouped_hash_stream.rs} | 2 +-
.../{topk_stream.rs => grouped_topk_stream.rs} | 0
.../{hash_aggregate.rs => hash_stream.rs} | 2 +-
datafusion/physical-plan/src/aggregates/mod.rs | 159 ++-
.../src/aggregates/partial_reduce_stream.rs | 2 +-
.../{partial_reduce_stream.rs => single_stream.rs} | 152 ++-
.../physical-plan/src/aggregates/skip_partial.rs | 6 +-
.../physical-plan/src/aggregates/topk/heap.rs | 5 +-
datafusion/physical-plan/src/analyze.rs | 8 +-
datafusion/physical-plan/src/async_func.rs | 22 +-
datafusion/physical-plan/src/buffer.rs | 22 +-
datafusion/physical-plan/src/coalesce_batches.rs | 22 +-
.../physical-plan/src/coalesce_partitions.rs | 22 +-
datafusion/physical-plan/src/coop.rs | 20 +-
datafusion/physical-plan/src/display.rs | 8 +-
.../physical-plan/src/distribution_requirements.rs | 510 +++++++++
datafusion/physical-plan/src/execution_plan.rs | 432 +++++++-
datafusion/physical-plan/src/filter.rs | 22 +-
datafusion/physical-plan/src/joins/array_map.rs | 102 +-
datafusion/physical-plan/src/joins/cross_join.rs | 42 +-
.../physical-plan/src/joins/hash_join/exec.rs | 167 ++-
.../src/joins/hash_join/shared_bounds.rs | 227 ++++
.../physical-plan/src/joins/nested_loop_join.rs | 52 +-
.../src/joins/piecewise_merge_join/exec.rs | 65 +-
.../src/joins/sort_merge_join/exec.rs | 36 +-
.../src/joins/sort_merge_join/tests.rs | 306 +++++-
.../physical-plan/src/joins/symmetric_hash_join.rs | 36 +-
datafusion/physical-plan/src/joins/utils.rs | 6 +-
datafusion/physical-plan/src/lib.rs | 4 +
datafusion/physical-plan/src/limit.rs | 50 +-
datafusion/physical-plan/src/projection.rs | 22 +-
datafusion/physical-plan/src/recursive_query.rs | 8 +-
datafusion/physical-plan/src/repartition/mod.rs | 614 ++++++++---
datafusion/physical-plan/src/sorts/merge.rs | 107 +-
datafusion/physical-plan/src/sorts/partial_sort.rs | 30 +-
.../physical-plan/src/sorts/partitioned_topk.rs | 8 +-
datafusion/physical-plan/src/sorts/sort.rs | 8 +-
.../src/sorts/sort_preserving_merge.rs | 30 +-
datafusion/physical-plan/src/union.rs | 48 +-
datafusion/physical-plan/src/unnest.rs | 30 +-
.../src/windows/bounded_window_agg_exec.rs | 30 +-
.../physical-plan/src/windows/window_agg_exec.rs | 30 +-
datafusion/proto-common/gen/src/main.rs | 6 +-
datafusion/proto-common/src/to_proto/mod.rs | 4 +-
datafusion/proto-models/gen/src/main.rs | 6 +-
datafusion/proto-models/proto/datafusion.proto | 40 +
datafusion/proto-models/src/generated/pbjson.rs | 1101 +++++++++++++++++---
datafusion/proto-models/src/generated/prost.rs | 62 +-
datafusion/proto/src/logical_plan/from_proto.rs | 30 +-
datafusion/proto/src/logical_plan/to_proto.rs | 39 +-
datafusion/proto/src/physical_plan/from_proto.rs | 78 +-
datafusion/proto/src/physical_plan/mod.rs | 20 +-
datafusion/proto/src/physical_plan/to_proto.rs | 21 +-
datafusion/proto/tests/cases/mod.rs | 69 +-
.../proto/tests/cases/roundtrip_logical_plan.rs | 167 ++-
.../proto/tests/cases/roundtrip_physical_plan.rs | 208 +++-
datafusion/proto/tests/cases/serialize.rs | 97 +-
datafusion/spark/src/function/array/shuffle.rs | 8 +-
datafusion/spark/src/function/array/slice.rs | 2 +-
datafusion/sql/src/planner.rs | 4 +-
datafusion/sql/src/statement.rs | 1 -
datafusion/sql/src/unparser/expr.rs | 2 +-
datafusion/sqllogictest/bin/sqllogictests.rs | 10 +-
.../src/test_context/range_partitioning.rs | 29 +-
datafusion/sqllogictest/test_files/aggregate.slt | 142 +++
.../test_files/aggregate_skip_partial.slt | 38 +
.../sqllogictest/test_files/aggregates_topk.slt | 12 +-
.../test_files/array/array_distinct.slt | 9 +-
.../sqllogictest/test_files/array/array_empty.slt | 15 +-
.../sqllogictest/test_files/array/array_first.slt | 127 +++
.../sqllogictest/test_files/array/array_has.slt | 16 +-
.../sqllogictest/test_files/array/array_index.slt | 109 +-
.../sqllogictest/test_files/array/array_pop.slt | 12 +-
.../test_files/array/array_position.slt | 6 +-
.../test_files/array/array_prepend.slt | 1 -
.../sqllogictest/test_files/array/array_resize.slt | 17 +
.../sqllogictest/test_files/array/cardinality.slt | 41 +-
.../sqllogictest/test_files/arrow_typeof.slt | 19 +-
datafusion/sqllogictest/test_files/binary.slt | 2 +-
datafusion/sqllogictest/test_files/clickbench.slt | 134 +--
datafusion/sqllogictest/test_files/copy.slt | 34 +-
.../test_files/datetime/timestamps.slt | 6 +-
datafusion/sqllogictest/test_files/ddl.slt | 4 -
datafusion/sqllogictest/test_files/dictionary.slt | 118 +++
.../test_files/eliminate_outer_join.slt | 75 ++
.../sqllogictest/test_files/explain_analyze.slt | 4 +-
datafusion/sqllogictest/test_files/expr.slt | 133 ++-
datafusion/sqllogictest/test_files/functions.slt | 38 +-
datafusion/sqllogictest/test_files/group_by.slt | 36 +-
datafusion/sqllogictest/test_files/in_list.slt | 96 ++
.../sqllogictest/test_files/information_schema.slt | 2 +-
.../sqllogictest/test_files/insert_to_external.slt | 6 +-
datafusion/sqllogictest/test_files/joins.slt | 12 +-
datafusion/sqllogictest/test_files/limit.slt | 8 +-
datafusion/sqllogictest/test_files/map.slt | 134 ++-
datafusion/sqllogictest/test_files/order.slt | 8 +-
.../test_files/preserve_file_partitioning.slt | 16 +-
.../test_files/projection_pushdown.slt | 63 +-
.../test_files/push_down_filter_parquet.slt | 5 +-
datafusion/sqllogictest/test_files/pwmj.slt | 26 +-
.../sqllogictest/test_files/range_partitioning.slt | 405 ++++++-
datafusion/sqllogictest/test_files/references.slt | 4 +-
.../test_files/repartition_subset_satisfaction.slt | 24 +-
datafusion/sqllogictest/test_files/scalar.slt | 51 +
datafusion/sqllogictest/test_files/select.slt | 8 +-
datafusion/sqllogictest/test_files/subquery.slt | 19 +
.../sqllogictest/test_files/subquery_sort.slt | 22 +-
datafusion/sqllogictest/test_files/topk.slt | 9 +-
.../sqllogictest/test_files/tpch/plans/q1.slt.part | 4 +-
.../test_files/tpch/plans/q10.slt.part | 4 +-
.../test_files/tpch/plans/q11.slt.part | 4 +-
.../test_files/tpch/plans/q12.slt.part | 4 +-
.../test_files/tpch/plans/q13.slt.part | 4 +-
.../test_files/tpch/plans/q16.slt.part | 4 +-
.../test_files/tpch/plans/q21.slt.part | 4 +-
.../test_files/tpch/plans/q22.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q3.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q4.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q5.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q7.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q9.slt.part | 4 +-
datafusion/sqllogictest/test_files/unnest.slt | 16 +-
datafusion/sqllogictest/test_files/window.slt | 30 +-
datafusion/substrait/src/physical_plan/producer.rs | 10 +-
docs/pyproject.toml | 2 +-
.../contributor-guide/development_environment.md | 2 +-
.../library-user-guide/functions/adding-udfs.md | 12 +-
docs/source/library-user-guide/upgrading/54.0.0.md | 4 -
docs/source/library-user-guide/upgrading/55.0.0.md | 104 ++
docs/source/user-guide/configs.md | 2 +-
docs/source/user-guide/introduction.md | 1 +
docs/source/user-guide/sql/scalar_functions.md | 34 +
rust-toolchain.toml | 2 +-
tmp/window_kernel_refactor.md | 213 ----
uv.lock | 57 +-
283 files changed, 13057 insertions(+), 4036 deletions(-)
copy datafusion/core/tests/{datasource => helper}/mod.rs (71%)
create mode 100644 datafusion/core/tests/helper/plan_metrics.rs
create mode 100644 datafusion/datasource-parquet/src/projection_read_plan.rs
create mode 100644 datafusion/functions-nested/src/array_first.rs
create mode 100644 datafusion/functions/benches/date_part.rs
create mode 100644
datafusion/physical-plan/src/aggregates/aggregate_hash_table/single_table.rs
rename datafusion/physical-plan/src/aggregates/{no_grouping.rs =>
aggregate_stream.rs} (100%)
rename datafusion/physical-plan/src/aggregates/{row_hash.rs =>
grouped_hash_stream.rs} (99%)
rename datafusion/physical-plan/src/aggregates/{topk_stream.rs =>
grouped_topk_stream.rs} (100%)
rename datafusion/physical-plan/src/aggregates/{hash_aggregate.rs =>
hash_stream.rs} (99%)
copy datafusion/physical-plan/src/aggregates/{partial_reduce_stream.rs =>
single_stream.rs} (67%)
create mode 100644 datafusion/physical-plan/src/distribution_requirements.rs
create mode 100644 datafusion/sqllogictest/test_files/array/array_first.slt
delete mode 100644 tmp/window_kernel_refactor.md
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
