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/datafusion.git
from 7c08a6fd00 refactor: Move SchemaAdapter from parquet module to data
source (#10680)
add ae107548bd Add reference visitor `TreeNode` APIs, change
`ExecutionPlan::children()` and `PhysicalExpr::children()` return references
(#10543)
No new revisions were added by this update.
Summary of changes:
datafusion-examples/examples/custom_datasource.rs | 2 +-
datafusion/common/src/tree_node.rs | 135 +++++++++++++++++----
.../src/datasource/physical_plan/arrow_file.rs | 2 +-
.../core/src/datasource/physical_plan/avro.rs | 2 +-
.../core/src/datasource/physical_plan/csv.rs | 2 +-
.../core/src/datasource/physical_plan/json.rs | 2 +-
.../src/datasource/physical_plan/parquet/mod.rs | 2 +-
datafusion/core/src/execution/context/mod.rs | 4 +-
.../src/physical_optimizer/aggregate_statistics.rs | 2 +-
.../src/physical_optimizer/enforce_distribution.rs | 4 +-
.../core/src/physical_optimizer/enforce_sorting.rs | 2 +-
.../limited_distinct_aggregation.rs | 4 +-
.../src/physical_optimizer/output_requirements.rs | 6 +-
.../src/physical_optimizer/projection_pushdown.rs | 8 +-
.../core/src/physical_optimizer/sort_pushdown.rs | 2 +-
.../src/physical_optimizer/topk_aggregation.rs | 2 +-
datafusion/core/src/physical_planner.rs | 2 +-
datafusion/core/src/test/mod.rs | 2 +-
datafusion/core/src/test_util/mod.rs | 2 +-
datafusion/core/src/test_util/parquet.rs | 2 +-
datafusion/core/tests/custom_sources_cases/mod.rs | 4 +-
.../provider_filter_pushdown.rs | 2 +-
.../core/tests/custom_sources_cases/statistics.rs | 2 +-
datafusion/core/tests/fuzz_cases/aggregate_fuzz.rs | 4 +-
datafusion/core/tests/parquet/filter_pushdown.rs | 2 +-
.../core/tests/user_defined/user_defined_plan.rs | 4 +-
datafusion/expr/src/logical_plan/display.rs | 14 +--
datafusion/expr/src/logical_plan/plan.rs | 18 +--
datafusion/expr/src/logical_plan/tree_node.rs | 35 ++----
datafusion/expr/src/tree_node.rs | 34 +++---
.../optimizer/src/common_subexpr_eliminate.rs | 6 +-
.../physical-expr-common/src/expressions/column.rs | 2 +-
.../physical-expr-common/src/physical_expr.rs | 2 +-
datafusion/physical-expr-common/src/tree_node.rs | 9 +-
datafusion/physical-expr-common/src/utils.rs | 7 +-
datafusion/physical-expr/src/equivalence/class.rs | 2 +-
datafusion/physical-expr/src/expressions/binary.rs | 4 +-
datafusion/physical-expr/src/expressions/case.rs | 60 +++++----
datafusion/physical-expr/src/expressions/cast.rs | 4 +-
datafusion/physical-expr/src/expressions/column.rs | 2 +-
.../physical-expr/src/expressions/in_list.rs | 6 +-
.../physical-expr/src/expressions/is_not_null.rs | 4 +-
.../physical-expr/src/expressions/is_null.rs | 4 +-
datafusion/physical-expr/src/expressions/like.rs | 4 +-
.../physical-expr/src/expressions/literal.rs | 2 +-
.../physical-expr/src/expressions/negative.rs | 4 +-
datafusion/physical-expr/src/expressions/no_op.rs | 2 +-
datafusion/physical-expr/src/expressions/not.rs | 4 +-
.../physical-expr/src/expressions/try_cast.rs | 4 +-
datafusion/physical-expr/src/scalar_function.rs | 4 +-
datafusion/physical-plan/src/aggregates/mod.rs | 6 +-
datafusion/physical-plan/src/analyze.rs | 4 +-
datafusion/physical-plan/src/coalesce_batches.rs | 4 +-
.../physical-plan/src/coalesce_partitions.rs | 4 +-
datafusion/physical-plan/src/display.rs | 2 +-
datafusion/physical-plan/src/empty.rs | 2 +-
datafusion/physical-plan/src/explain.rs | 2 +-
datafusion/physical-plan/src/filter.rs | 4 +-
datafusion/physical-plan/src/insert.rs | 4 +-
datafusion/physical-plan/src/joins/cross_join.rs | 4 +-
datafusion/physical-plan/src/joins/hash_join.rs | 4 +-
.../physical-plan/src/joins/nested_loop_join.rs | 4 +-
.../physical-plan/src/joins/sort_merge_join.rs | 4 +-
.../physical-plan/src/joins/symmetric_hash_join.rs | 4 +-
datafusion/physical-plan/src/lib.rs | 6 +-
datafusion/physical-plan/src/limit.rs | 8 +-
datafusion/physical-plan/src/memory.rs | 2 +-
datafusion/physical-plan/src/placeholder_row.rs | 2 +-
datafusion/physical-plan/src/projection.rs | 4 +-
datafusion/physical-plan/src/recursive_query.rs | 8 +-
datafusion/physical-plan/src/repartition/mod.rs | 4 +-
datafusion/physical-plan/src/sorts/partial_sort.rs | 4 +-
datafusion/physical-plan/src/sorts/sort.rs | 4 +-
.../src/sorts/sort_preserving_merge.rs | 4 +-
datafusion/physical-plan/src/streaming.rs | 2 +-
datafusion/physical-plan/src/test/exec.rs | 12 +-
datafusion/physical-plan/src/tree_node.rs | 9 +-
datafusion/physical-plan/src/union.rs | 8 +-
datafusion/physical-plan/src/unnest.rs | 4 +-
datafusion/physical-plan/src/values.rs | 2 +-
.../src/windows/bounded_window_agg_exec.rs | 4 +-
.../physical-plan/src/windows/window_agg_exec.rs | 4 +-
datafusion/physical-plan/src/work_table.rs | 2 +-
datafusion/proto/src/physical_plan/mod.rs | 1 +
84 files changed, 338 insertions(+), 252 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
