This is an automated email from the ASF dual-hosted git repository.
alamb pushed a change to branch dependabot/cargo/main/nix-0.27.1
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
from 77c227c22a Update nix requirement from 0.26.1 to 0.27.1
add c7a93fcd02 Minor(proto): Implement `TryFrom<&DFSchema>` for
`protobuf::DfSchema` (#7505)
add 495c25f7d8 fix: inconsistent behaviors when dividing floating numbers
by zero (#7503)
add abea8938b5 Parallelize Stateless (CSV/JSON) File Write Serialization
(#7452)
add cc8ae61a79 Remove stray comment markings from encoding error message
(#7512)
add 7b9bb08c67 Remove implicit interval type coercion from ScalarValue
comparison (#7514)
add 0cd30886cd Minor: deprecate ScalarValue::get_datatype() (#7507)
add c3898cf9fd Propagate error from spawned task reading spills (#7510)
add 60e00b3a65 Refactor the EnforceDistribution Rule (#7488)
add 63ccd4ab8b Remove get_scan_files and ExecutionPlan::file_scan_config
(#7357) (#7487)
add 4abae3b4fa Simplify ScalarValue::distance (#7517) (#7519)
add 9b5733fe61 typo: change delimeter to delimiter (#7521)
add 87527c4308 Fix some simplification rules for floating-point arithmetic
operations (#7515)
add 561e0d7e87 Documentation Updates for New Write Related Features (#7520)
add cf229b82cb Move tests from repartition to enforce_distribution (#7539)
add 3580558305 Update Cargo.toml (#7541)
add 4fac0e1f7a Fix flaky test_sort_fetch_memory_calculation (#7534)
add 11b72d6765 Move common code to utils (#7545)
add 8e2a0e6e8f Minor: Add comments and clearer constructors to `Interval`
(#7526)
add a758270730 fix: skip EliminateCrossJoin rule if inner join with filter
is found (#7529)
add 812864b3b6 Create a Priority Queue based Aggregation with `limit`
(#7192)
add 8946f8bd34 feat: add guarantees to simplification (#7467)
add cde74016e9 [Minor]: Produce better plan when group by contains all of
the ordering requirements (#7542)
add c2fb263d7f Minor: beautify interval display (#7554)
add f76a8cda4d replace ptree with termtree (#7560)
add 58ddceef50 Make AvroArrowArrayReader possible to scan Avro backed
table which contains nested records (#7525)
add 284514308a Fix a race condition issue on reading spilled file (#7538)
add 9c993a340a Add is single method (#7558)
add 93e14a7079 Fix `describe <table>` to work without SessionContext
(#7441)
add e9723ee3b1 Make the tests in SHJ faster (#7543)
add f1f8d79ab8 feat: Support spilling for hash aggregation (#7400)
add 1a986c2aa2 Make backtrace as a cargo feature (#7527)
add 4055c003c8 Minor: Fix `clippy` by switching to `timestamp_nanos_opt`
instead of (deprecated) `timestamp_nanos` (#7572)
add 261b900472 Update sqllogictest requirement from 0.15.0 to 0.16.0
(#7569)
add 7b12666ec8 extract `datafusion-physical-plan` to its own crate (#7432)
add 61ed374e96 First and Last Accumulators should update with state row
excluding is_set flag (#7565)
add 93f78b28ac refactor: simplify code of eliminate_cross_join.rs (#7561)
add a0a8e51628 Update release instructions for datafusion-physical-plan
crate (#7576)
add e9b3a329fc Minor: Update chrono pin (#7575)
add 678d27af3c [feat] Introduce cacheManager in session ctx and make
StatisticsCache share in session (#7570)
add c72b98e414 Enhance/Refactor Ordering Equivalence Properties (#7566)
add d68c0fcb49 fix misplaced statements in sqllogictest (#7586)
add dfce6ea57c Update substrait requirement from 0.13.1 to 0.14.0 (#7585)
add f2298c2a72 chore: use the `create_udwf` function in `simple_udwf`,
consistent with `simple_udf` and `simple_udaf` (#7579)
add 938505b8f7 Implement protobuf serialization for AnalyzeExec (#7574)
add 44b3318c2a chore: fix catalog's usage docs error and add notes about
`CatalogList` trait (#7582)
add f4c4ee1e7f Implement `CardinalityAwareRowConverter` while doing
streaming merge (#7401)
add 5718a3f2e1 Parallelize Parquet Serialization (#7562)
add d512bee11b feat: natively support more data types for the `abs`
function. (#7568)
add 81f33b0e27 implement string_to_array (#7577)
add eba06c39a8 Merge remote-tracking branch 'apache/main' into
dependabot/cargo/main/nix-0.27.1
add 6412487239 enable fs feature
No new revisions were added by this update.
Summary of changes:
.github/workflows/rust.yml | 8 +-
Cargo.toml | 4 +-
datafusion-cli/Cargo.lock | 165 +-
datafusion-examples/examples/simple_udwf.rs | 42 +-
datafusion/common/Cargo.toml | 3 +-
datafusion/common/src/config.rs | 13 +
datafusion/common/src/error.rs | 64 +-
datafusion/common/src/file_options/csv_writer.rs | 4 +-
datafusion/common/src/file_options/mod.rs | 2 +-
datafusion/common/src/file_options/parse_utils.rs | 4 +-
datafusion/common/src/lib.rs | 3 +
datafusion/common/src/scalar.rs | 282 +-
datafusion/common/src/stats.rs | 24 +
datafusion/common/src/test_util.rs | 79 +
datafusion/core/Cargo.toml | 14 +-
datafusion/core/benches/topk_aggregate.rs | 239 ++
.../datasource/avro_to_arrow/arrow_array_reader.rs | 53 +-
datafusion/core/src/datasource/file_format/csv.rs | 9 +
datafusion/core/src/datasource/file_format/json.rs | 5 +
.../core/src/datasource/file_format/parquet.rs | 407 +-
.../core/src/datasource/file_format/write.rs | 278 +-
datafusion/core/src/datasource/listing/table.rs | 180 +-
.../core/src/datasource/listing_table_factory.rs | 20 +-
.../core/src/datasource/physical_plan/avro.rs | 4 -
.../core/src/datasource/physical_plan/csv.rs | 4 -
.../datasource/physical_plan/file_scan_config.rs | 70 +-
.../core/src/datasource/physical_plan/json.rs | 4 -
.../core/src/datasource/physical_plan/mod.rs | 5 +-
.../core/src/datasource/physical_plan/parquet.rs | 4 -
datafusion/core/src/execution/context.rs | 58 +-
datafusion/core/src/lib.rs | 10 +-
.../combine_partial_final_agg.rs | 105 +-
.../src/physical_optimizer/dist_enforcement.rs | 2193 ----------
.../src/physical_optimizer/enforce_distribution.rs | 4392 ++++++++++++++++++++
.../{sort_enforcement.rs => enforce_sorting.rs} | 146 +-
.../core/src/physical_optimizer/join_selection.rs | 4 +-
datafusion/core/src/physical_optimizer/mod.rs | 6 +-
.../core/src/physical_optimizer/optimizer.rs | 25 +-
.../core/src/physical_optimizer/repartition.rs | 1353 ------
.../replace_with_order_preserving_variants.rs | 7 +-
.../core/src/physical_optimizer/sort_pushdown.rs | 39 +-
.../core/src/physical_optimizer/test_utils.rs | 16 +-
.../src/physical_optimizer/topk_aggregation.rs | 176 +
datafusion/core/src/physical_optimizer/utils.rs | 76 +-
datafusion/core/src/physical_planner.rs | 54 +-
datafusion/core/src/test/mod.rs | 161 +-
datafusion/core/src/test_util/mod.rs | 80 +-
datafusion/core/tests/dataframe/describe.rs | 96 +
datafusion/core/tests/dataframe/mod.rs | 59 +-
datafusion/core/tests/memory_limit.rs | 122 +-
datafusion/core/tests/parquet/file_statistics.rs | 116 +
datafusion/core/tests/parquet/mod.rs | 4 +-
datafusion/core/tests/path_partition.rs | 4 +-
datafusion/core/tests/sql/describe.rs | 72 +
datafusion/core/tests/sql/displayable.rs | 57 +
datafusion/core/tests/sql/explain_analyze.rs | 9 +-
datafusion/core/tests/sql/group_by.rs | 91 +
datafusion/core/tests/sql/joins.rs | 28 +-
datafusion/core/tests/sql/mod.rs | 4 +-
datafusion/execution/Cargo.toml | 3 +-
datafusion/execution/src/cache/cache_manager.rs | 74 +
datafusion/execution/src/cache/cache_unit.rs | 140 +
datafusion/execution/src/cache/mod.rs | 52 +
datafusion/execution/src/disk_manager.rs | 81 +-
datafusion/execution/src/lib.rs | 1 +
datafusion/execution/src/runtime_env.rs | 17 +-
datafusion/expr/src/built_in_function.rs | 27 +-
datafusion/expr/src/columnar_value.rs | 2 +-
datafusion/expr/src/expr_fn.rs | 4 +-
datafusion/expr/src/expr_schema.rs | 2 +-
datafusion/expr/src/logical_plan/plan.rs | 38 +-
datafusion/expr/src/utils.rs | 34 +-
datafusion/optimizer/Cargo.toml | 2 +-
datafusion/optimizer/src/analyzer/type_coercion.rs | 4 +-
datafusion/optimizer/src/eliminate_cross_join.rs | 160 +-
.../src/simplify_expressions/expr_simplifier.rs | 225 +-
.../src/simplify_expressions/guarantees.rs | 520 +++
.../optimizer/src/simplify_expressions/mod.rs | 1 +
.../src/simplify_expressions/simplify_exprs.rs | 4 +-
datafusion/physical-expr/Cargo.toml | 2 +-
.../src/aggregate/array_agg_ordered.rs | 4 +-
.../physical-expr/src/aggregate/first_last.rs | 85 +-
datafusion/physical-expr/src/aggregate/utils.rs | 51 +
datafusion/physical-expr/src/analysis.rs | 11 +-
datafusion/physical-expr/src/array_expressions.rs | 123 +-
.../physical-expr/src/datetime_expressions.rs | 13 +-
datafusion/physical-expr/src/equivalence.rs | 604 ++-
.../physical-expr/src/expressions/literal.rs | 2 +-
datafusion/physical-expr/src/expressions/mod.rs | 4 +-
datafusion/physical-expr/src/expressions/not.rs | 2 +-
datafusion/physical-expr/src/expressions/nullif.rs | 2 +-
datafusion/physical-expr/src/functions.rs | 21 +-
.../physical-expr/src/intervals/cp_solver.rs | 16 +-
.../src/intervals/interval_aritmetic.rs | 384 +-
datafusion/physical-expr/src/lib.rs | 12 +-
datafusion/physical-expr/src/math_expressions.rs | 74 +-
datafusion/physical-expr/src/partitioning.rs | 19 +-
datafusion/physical-expr/src/physical_expr.rs | 11 +
datafusion/physical-expr/src/utils.rs | 446 +-
.../{physical-expr => physical-plan}/Cargo.toml | 49 +-
.../src}/aggregates/group_values/mod.rs | 6 +-
.../src}/aggregates/group_values/primitive.rs | 23 +-
.../src}/aggregates/group_values/row.rs | 74 +-
.../src}/aggregates/mod.rs | 379 +-
.../src}/aggregates/no_grouping.rs | 8 +-
.../src}/aggregates/order/full.rs | 2 +-
.../src}/aggregates/order/mod.rs | 0
.../src}/aggregates/order/partial.rs | 13 +-
.../src}/aggregates/row_hash.rs | 315 +-
.../src/aggregates/topk/hash_table.rs | 425 ++
.../physical-plan/src/aggregates/topk/heap.rs | 627 +++
.../src/aggregates/topk}/mod.rs | 7 +-
.../src/aggregates/topk/priority_map.rs | 381 ++
.../physical-plan/src/aggregates/topk_stream.rs | 180 +
.../physical_plan => physical-plan/src}/analyze.rs | 19 +-
.../src}/coalesce_batches.rs | 29 +-
.../src}/coalesce_partitions.rs | 14 +-
.../physical_plan => physical-plan/src}/common.rs | 16 +-
.../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 | 99 +-
.../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 | 8 +-
.../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 | 434 +-
.../src}/joins/test_utils.rs | 33 +-
.../src}/joins/utils.rs | 234 +-
.../mod.rs => physical-plan/src/lib.rs} | 55 +-
.../physical_plan => physical-plan/src}/limit.rs | 58 +-
.../physical_plan => physical-plan/src}/memory.rs | 12 +-
.../src}/metrics/baseline.rs | 2 +-
.../src}/metrics/builder.rs | 2 +-
.../src}/metrics/mod.rs | 2 +-
.../src}/metrics/value.rs | 6 +-
.../src}/projection.rs | 110 +-
.../src}/repartition/distributor_channels.rs | 0
.../src}/repartition/mod.rs | 94 +-
datafusion/physical-plan/src/row_converter.rs | 295 ++
.../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 | 154 +-
.../src}/sorts/sort_preserving_merge.rs | 140 +-
.../src}/sorts/stream.rs | 13 +-
.../physical_plan => physical-plan/src}/stream.rs | 29 +-
.../src}/streaming.rs | 6 +-
datafusion/physical-plan/src/test.rs | 123 +
.../{core => physical-plan}/src/test/exec.rs | 21 +-
.../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 +-
datafusion/proto/Cargo.toml | 2 +-
datafusion/proto/proto/datafusion.proto | 9 +
datafusion/proto/src/generated/pbjson.rs | 159 +
datafusion/proto/src/generated/prost.rs | 19 +-
datafusion/proto/src/logical_plan/from_proto.rs | 3 +-
datafusion/proto/src/logical_plan/mod.rs | 40 +-
datafusion/proto/src/logical_plan/to_proto.rs | 19 +-
datafusion/proto/src/physical_plan/mod.rs | 52 +-
datafusion/proto/src/physical_plan/to_proto.rs | 8 +-
datafusion/sql/src/statement.rs | 4 +-
datafusion/sqllogictest/Cargo.toml | 6 +-
datafusion/sqllogictest/test_files/aggregate.slt | 159 +-
datafusion/sqllogictest/test_files/array.slt | 46 +
datafusion/sqllogictest/test_files/avro.slt | 13 +
datafusion/sqllogictest/test_files/copy.slt | 2 +-
datafusion/sqllogictest/test_files/decimal.slt | 9 +-
datafusion/sqllogictest/test_files/encoding.slt | 4 +-
datafusion/sqllogictest/test_files/errors.slt | 4 +-
datafusion/sqllogictest/test_files/explain.slt | 2 +-
datafusion/sqllogictest/test_files/functions.slt | 2 +-
datafusion/sqllogictest/test_files/groupby.slt | 38 +-
.../sqllogictest/test_files/information_schema.slt | 2 +
.../sqllogictest/test_files/intersection.slt | 1 -
datafusion/sqllogictest/test_files/joins.slt | 63 +-
datafusion/sqllogictest/test_files/math.slt | 435 ++
datafusion/sqllogictest/test_files/scalar.slt | 6 +-
datafusion/sqllogictest/test_files/select.slt | 106 +
.../sqllogictest/test_files/set_variable.slt | 20 +-
datafusion/sqllogictest/test_files/subquery.slt | 25 +-
.../test_files/tpch/drop_tables.slt.part | 2 -
.../sqllogictest/test_files/tpch/q15.slt.part | 28 +-
datafusion/sqllogictest/test_files/union.slt | 15 +-
datafusion/sqllogictest/test_files/window.slt | 10 +-
datafusion/substrait/Cargo.toml | 4 +-
dev/release/README.md | 2 +
dev/release/crate-deps.dot | 8 +-
dev/release/crate-deps.svg | 184 +-
docs/source/library-user-guide/catalogs.md | 51 +-
docs/source/user-guide/configs.md | 2 +
docs/source/user-guide/expressions.md | 2 +-
docs/source/user-guide/sql/ddl.md | 4 +-
docs/source/user-guide/sql/dml.md | 12 +-
docs/source/user-guide/sql/index.rst | 1 +
docs/source/user-guide/sql/scalar_functions.md | 28 +-
docs/source/user-guide/sql/write_options.md | 131 +
parquet-testing | 2 +-
testing | 2 +-
211 files changed, 14493 insertions(+), 7091 deletions(-)
create mode 100644 datafusion/core/benches/topk_aggregate.rs
delete mode 100644 datafusion/core/src/physical_optimizer/dist_enforcement.rs
create mode 100644
datafusion/core/src/physical_optimizer/enforce_distribution.rs
rename datafusion/core/src/physical_optimizer/{sort_enforcement.rs =>
enforce_sorting.rs} (96%)
delete mode 100644 datafusion/core/src/physical_optimizer/repartition.rs
create mode 100644 datafusion/core/src/physical_optimizer/topk_aggregation.rs
create mode 100644 datafusion/core/tests/dataframe/describe.rs
create mode 100644 datafusion/core/tests/parquet/file_statistics.rs
create mode 100644 datafusion/core/tests/sql/describe.rs
create mode 100644 datafusion/core/tests/sql/displayable.rs
create mode 100644 datafusion/execution/src/cache/cache_manager.rs
create mode 100644 datafusion/execution/src/cache/cache_unit.rs
create mode 100644 datafusion/execution/src/cache/mod.rs
create mode 100644 datafusion/optimizer/src/simplify_expressions/guarantees.rs
copy datafusion/{physical-expr => physical-plan}/Cargo.toml (59%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/mod.rs (90%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/primitive.rs (91%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/group_values/row.rs (73%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/mod.rs (86%)
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 (96%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/aggregates/row_hash.rs (54%)
create mode 100644 datafusion/physical-plan/src/aggregates/topk/hash_table.rs
create mode 100644 datafusion/physical-plan/src/aggregates/topk/heap.rs
copy datafusion/{expr/src/tree_node =>
physical-plan/src/aggregates/topk}/mod.rs (89%)
create mode 100644 datafusion/physical-plan/src/aggregates/topk/priority_map.rs
create mode 100644 datafusion/physical-plan/src/aggregates/topk_stream.rs
rename datafusion/{core/src/physical_plan => physical-plan/src}/analyze.rs
(96%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/coalesce_batches.rs (94%)
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 (86%)
rename datafusion/{core/src/physical_plan =>
physical-plan/src}/joins/test_utils.rs (96%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/joins/utils.rs
(92%)
rename datafusion/{core/src/physical_plan/mod.rs => physical-plan/src/lib.rs}
(86%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/limit.rs (93%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/memory.rs (97%)
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 (99%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/projection.rs
(85%)
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 (95%)
create mode 100644 datafusion/physical-plan/src/row_converter.rs
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
(90%)
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 (95%)
rename datafusion/{core/src/physical_plan => physical-plan/src}/stream.rs (95%)
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%)
create mode 100644 docs/source/user-guide/sql/write_options.md
