You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2023/06/20 21:25:51 UTC
[arrow-datafusion] branch vectorized_collision updated (e586eb877f -> 50e2b2255c)
This is an automated email from the ASF dual-hosted git repository.
dheres pushed a change to branch vectorized_collision
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from e586eb877f Add back comment
add feb4b8fbe1 refactor: alias() should skip add alias for `Expr::Sort` (#6707)
add faac34c5a2 chore(deps): update strum/strum_macros requirement from 0.24 to 0.25 (#6717)
add cae8cc2764 Move alias generator to per-query execution props (#6706)
add d29ab93150 fix: parser for negative intervals (#6698)
add 0ef9478e66 Minor: Improve UX for setting ExecutionProps::query_execution_start_time (#6719)
add 39666eb847 add Eq and PartialEq to ListingTableUrl (#6725)
add 748f4bed8a Support Expr::InList to Substrait::RexType (#6604)
add da9d2616d3 MINOR: Add maintains input order flag to CoalesceBatches (#6730)
add d32f9a7425 Update copyight date on website (#6727)
add f0e02abb67 Display all partitions and files in EXPLAIN VERBOSE (#6711)
add e0330d6c95 Update `arrow`, `arrow-flight` and `parquet` to `42.0.0` (#6702)
add 50e2b2255c Merge
No new revisions were added by this update.
Summary of changes:
Cargo.toml | 12 +-
benchmarks/src/bin/tpch.rs | 4 +-
datafusion-cli/Cargo.lock | 185 +++---
datafusion-cli/Cargo.toml | 2 +-
datafusion/{optimizer => common}/src/alias.rs | 1 +
datafusion/common/src/lib.rs | 1 +
datafusion/core/src/datasource/file_format/csv.rs | 25 +-
datafusion/core/src/datasource/listing/url.rs | 2 +-
datafusion/core/src/datasource/memory.rs | 16 +-
.../src/datasource/physical_plan/arrow_file.rs | 9 +-
.../core/src/datasource/physical_plan/avro.rs | 9 +-
.../core/src/datasource/physical_plan/csv.rs | 14 +-
.../core/src/datasource/physical_plan/json.rs | 9 +-
.../core/src/datasource/physical_plan/mod.rs | 185 ++++--
.../core/src/datasource/physical_plan/parquet.rs | 17 +-
datafusion/core/src/execution/context.rs | 5 +
.../combine_partial_final_agg.rs | 2 +-
.../src/physical_optimizer/dist_enforcement.rs | 4 +-
.../core/src/physical_optimizer/join_selection.rs | 2 +-
.../core/src/physical_optimizer/repartition.rs | 2 +-
.../src/physical_optimizer/sort_enforcement.rs | 24 +-
.../core/src/physical_plan/aggregates/mod.rs | 2 +-
datafusion/core/src/physical_plan/analyze.rs | 6 +-
.../core/src/physical_plan/coalesce_batches.rs | 6 +-
.../core/src/physical_plan/coalesce_partitions.rs | 2 +-
datafusion/core/src/physical_plan/display.rs | 55 +-
datafusion/core/src/physical_plan/empty.rs | 2 +-
datafusion/core/src/physical_plan/explain.rs | 2 +-
datafusion/core/src/physical_plan/filter.rs | 2 +-
datafusion/core/src/physical_plan/insert.rs | 12 +-
.../core/src/physical_plan/joins/cross_join.rs | 2 +-
.../core/src/physical_plan/joins/hash_join.rs | 2 +-
.../src/physical_plan/joins/nested_loop_join.rs | 2 +-
.../src/physical_plan/joins/sort_merge_join.rs | 2 +-
.../src/physical_plan/joins/symmetric_hash_join.rs | 6 +-
datafusion/core/src/physical_plan/limit.rs | 4 +-
datafusion/core/src/physical_plan/memory.rs | 2 +-
datafusion/core/src/physical_plan/mod.rs | 6 +-
datafusion/core/src/physical_plan/projection.rs | 2 +-
.../core/src/physical_plan/repartition/mod.rs | 2 +-
datafusion/core/src/physical_plan/sorts/sort.rs | 2 +-
.../physical_plan/sorts/sort_preserving_merge.rs | 2 +-
datafusion/core/src/physical_plan/union.rs | 4 +-
datafusion/core/src/physical_plan/unnest.rs | 2 +-
datafusion/core/src/physical_plan/values.rs | 2 +-
.../windows/bounded_window_agg_exec.rs | 2 +-
.../src/physical_plan/windows/window_agg_exec.rs | 2 +-
datafusion/core/src/physical_planner.rs | 22 +-
datafusion/core/src/test/exec.rs | 12 +-
datafusion/core/src/test_util/mod.rs | 2 +-
datafusion/core/tests/custom_sources.rs | 2 +-
.../provider_filter_pushdown.rs | 2 +-
.../core/tests/custom_sources_cases/statistics.rs | 2 +-
datafusion/core/tests/sql/explain_analyze.rs | 4 +-
datafusion/core/tests/sql/expr.rs | 9 +-
datafusion/core/tests/sql/order.rs | 2 +-
.../tests/sqllogictests/test_files/interval.slt | 8 +-
.../core/tests/sqllogictests/test_files/joins.slt | 64 +-
.../tests/sqllogictests/test_files/subquery.slt | 171 +++--
.../sqllogictests/test_files/tpch/q15.slt.part | 4 +-
.../sqllogictests/test_files/tpch/q17.slt.part | 4 +-
.../sqllogictests/test_files/tpch/q18.slt.part | 4 +-
.../sqllogictests/test_files/tpch/q2.slt.part | 6 +-
.../sqllogictests/test_files/tpch/q20.slt.part | 12 +-
.../sqllogictests/test_files/tpch/q21.slt.part | 8 +-
.../sqllogictests/test_files/tpch/q22.slt.part | 8 +-
.../sqllogictests/test_files/tpch/q4.slt.part | 4 +-
datafusion/core/tests/user_defined_plan.rs | 2 +-
datafusion/expr/Cargo.toml | 4 +-
datafusion/expr/src/expr.rs | 31 +-
datafusion/expr/src/expr_rewriter/mod.rs | 38 +-
.../src/decorrelate_predicate_subquery.rs | 12 +-
datafusion/optimizer/src/lib.rs | 1 -
datafusion/optimizer/src/merge_projection.rs | 6 +-
datafusion/optimizer/src/optimizer.rs | 12 +
datafusion/optimizer/src/push_down_projection.rs | 6 +-
.../optimizer/src/scalar_subquery_to_join.rs | 19 +-
.../src/simplify_expressions/expr_simplifier.rs | 8 +-
.../src/simplify_expressions/simplify_exprs.rs | 20 +-
datafusion/physical-expr/src/execution_props.rs | 21 +-
datafusion/sql/src/expr/mod.rs | 1 +
datafusion/sql/src/expr/unary_op.rs | 6 +
datafusion/sql/src/expr/value.rs | 12 +-
datafusion/sql/tests/sql_integration.rs | 26 +-
datafusion/substrait/src/logical_plan/consumer.rs | 86 ++-
datafusion/substrait/src/logical_plan/producer.rs | 43 +-
.../tests/cases/roundtrip_logical_plan.rs | 26 +-
.../tests/cases/roundtrip_physical_plan.rs | 7 +-
.../substrait/tests/roundtrip_logical_plan.rs | 733 +++++++++++++++++++++
datafusion/substrait/tests/testdata/data.csv | 6 +-
docs/source/conf.py | 2 +-
91 files changed, 1620 insertions(+), 523 deletions(-)
rename datafusion/{optimizer => common}/src/alias.rs (98%)
create mode 100644 datafusion/substrait/tests/roundtrip_logical_plan.rs