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 261b900472 Update sqllogictest requirement from 0.15.0 to 0.16.0
(#7569)
add 7b12666ec8 extract `datafusion-physical-plan` to its own crate (#7432)
No new revisions were added by this update.
Summary of changes:
Cargo.toml | 2 +-
datafusion-cli/Cargo.lock | 72 ++++++-
datafusion/common/src/lib.rs | 3 +
datafusion/common/src/test_util.rs | 79 ++++++++
datafusion/core/Cargo.toml | 3 +-
.../datasource/physical_plan/file_scan_config.rs | 30 ++-
datafusion/core/src/lib.rs | 10 +-
.../combine_partial_final_agg.rs | 105 +++++-----
.../src/physical_optimizer/enforce_distribution.rs | 40 ++--
.../core/src/physical_optimizer/join_selection.rs | 4 +-
.../core/src/physical_optimizer/sort_pushdown.rs | 20 +-
.../src/physical_optimizer/topk_aggregation.rs | 22 +--
datafusion/core/src/physical_planner.rs | 4 +-
datafusion/core/src/test/mod.rs | 161 ++++++++--------
datafusion/core/src/test_util/mod.rs | 80 +-------
datafusion/core/tests/sql/displayable.rs | 57 ++++++
datafusion/core/tests/sql/mod.rs | 1 +
datafusion/{optimizer => physical-plan}/Cargo.toml | 43 +++--
.../src}/aggregates/group_values/mod.rs | 0
.../src}/aggregates/group_values/primitive.rs | 2 +-
.../src}/aggregates/group_values/row.rs | 2 +-
.../src}/aggregates/mod.rs | 69 ++++---
.../src}/aggregates/no_grouping.rs | 8 +-
.../src}/aggregates/order/full.rs | 2 +-
.../src}/aggregates/order/mod.rs | 0
.../src}/aggregates/order/partial.rs | 2 +-
.../src}/aggregates/row_hash.rs | 20 +-
.../src}/aggregates/topk/hash_table.rs | 6 +-
.../src}/aggregates/topk/heap.rs | 2 +-
.../src}/aggregates/topk/mod.rs | 0
.../src}/aggregates/topk/priority_map.rs | 8 +-
.../src}/aggregates/topk_stream.rs | 6 +-
.../physical_plan => physical-plan/src}/analyze.rs | 4 +-
.../src}/coalesce_batches.rs | 25 ++-
.../src}/coalesce_partitions.rs | 14 +-
.../physical_plan => physical-plan/src}/common.rs | 10 +-
.../physical_plan => physical-plan/src}/display.rs | 11 +-
.../physical_plan => physical-plan/src}/empty.rs | 18 +-
.../physical_plan => physical-plan/src}/explain.rs | 4 +-
.../physical_plan => physical-plan/src}/filter.rs | 65 +------
.../physical_plan => physical-plan/src}/insert.rs | 2 +-
.../src}/joins/cross_join.rs | 22 ++-
.../src}/joins/hash_join.rs | 51 ++---
.../src}/joins/hash_join_utils.rs | 6 +-
.../src}/joins/mod.rs | 0
.../src}/joins/nested_loop_join.rs | 29 +--
.../src}/joins/sort_merge_join.rs | 56 ++++--
.../src}/joins/symmetric_hash_join.rs | 18 +-
.../src}/joins/test_utils.rs | 10 +-
.../src}/joins/utils.rs | 6 +-
.../mod.rs => physical-plan/src/lib.rs} | 48 +----
.../physical_plan => physical-plan/src}/limit.rs | 58 +++---
.../physical_plan => physical-plan/src}/memory.rs | 6 +-
.../src}/metrics/baseline.rs | 2 +-
.../src}/metrics/builder.rs | 2 +-
.../src}/metrics/mod.rs | 2 +-
.../src}/metrics/value.rs | 0
.../src}/projection.rs | 104 +---------
.../src}/repartition/distributor_channels.rs | 0
.../src}/repartition/mod.rs | 85 ++++----
.../src}/sorts/builder.rs | 0
.../src}/sorts/cursor.rs | 2 +-
.../src}/sorts/index.rs | 0
.../src}/sorts/merge.rs | 14 +-
.../src}/sorts/mod.rs | 0
.../src}/sorts/sort.rs | 138 ++++---------
.../src}/sorts/sort_preserving_merge.rs | 126 ++++--------
.../src}/sorts/stream.rs | 6 +-
.../physical_plan => physical-plan/src}/stream.rs | 2 +-
.../src}/streaming.rs | 6 +-
datafusion/physical-plan/src/test.rs | 123 ++++++++++++
.../{core => physical-plan}/src/test/exec.rs | 17 +-
.../src}/tree_node.rs | 2 +-
.../physical_plan => physical-plan/src}/udaf.rs | 2 +-
.../physical_plan => physical-plan/src}/union.rs | 18 +-
.../physical_plan => physical-plan/src}/unnest.rs | 8 +-
.../physical_plan => physical-plan/src}/values.rs | 33 ++--
.../physical_plan => physical-plan/src}/visitor.rs | 0
.../src}/windows/bounded_window_agg_exec.rs | 10 +-
.../src}/windows/mod.rs | 214 +--------------------
.../src}/windows/window_agg_exec.rs | 12 +-
81 files changed, 1029 insertions(+), 1225 deletions(-)
create mode 100644 datafusion/core/tests/sql/displayable.rs
copy datafusion/{optimizer => physical-plan}/Cargo.toml (60%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/mod.rs (100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/primitive.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/row.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/mod.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/no_grouping.rs (97%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/order/full.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/order/mod.rs (100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/order/partial.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/row_hash.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/topk/hash_table.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/topk/heap.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/topk/mod.rs (100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/topk/priority_map.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/topk_stream.rs (97%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/analyze.rs
(99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/coalesce_batches.rs (95%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/coalesce_partitions.rs (95%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/common.rs (98%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/display.rs
(98%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/empty.rs (94%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/explain.rs
(97%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/filter.rs (93%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/insert.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/cross_join.rs (97%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/hash_join.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/hash_join_utils.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/joins/mod.rs
(100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/nested_loop_join.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/sort_merge_join.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/symmetric_hash_join.rs (99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/test_utils.rs (98%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/joins/utils.rs
(99%)
rename datafusion/{core/src/physical_plan/mod.rs => physical-plan/src/lib.rs}
(88%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/limit.rs (93%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/memory.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/metrics/baseline.rs (98%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/metrics/builder.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/metrics/mod.rs
(99%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/metrics/value.rs (100%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/projection.rs
(86%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/repartition/distributor_channels.rs (100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/repartition/mod.rs (96%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/sorts/builder.rs (100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/sorts/cursor.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/sorts/index.rs
(100%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/sorts/merge.rs
(97%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/sorts/mod.rs
(100%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/sorts/sort.rs
(91%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/sorts/sort_preserving_merge.rs (91%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/sorts/stream.rs (97%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/stream.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/streaming.rs
(96%)
create mode 100644 datafusion/physical-plan/src/test.rs
rename datafusion/{core => physical-plan}/src/test/exec.rs (98%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/tree_node.rs
(94%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/udaf.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/union.rs (98%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/unnest.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/values.rs (91%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/visitor.rs
(100%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/windows/bounded_window_agg_exec.rs (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/windows/mod.rs
(69%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/windows/window_agg_exec.rs (98%)
