This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/cargo/main/getrandom-0.3.1
in repository https://gitbox.apache.org/repos/asf/datafusion.git
discard 11c617f19b chore(deps): update getrandom requirement from 0.2.8 to
0.3.1
add 5e46314c49 fix(doc): remove AWS_PROFILE from supported S3
configuration (#14492)
add 79b5658535 Fix link to volcano parallelism paper (#14497)
add 1cefe50410 chore(deps): bump aws-config from 1.5.15 to 1.5.16 in
/datafusion-cli (#14500)
add 2ad28e01e2 chore: Add more LIKE with escape tests (#14501)
add e7e1a1d815 Fix a clippy warning in `datafusion-sqllogictest` (#14506)
add 2db2bb91ff minor: improve PR template (#14507)
add 68ee07f193 Support `Dictionary` and `List` types in `scalar_to_sql`
(#14346)
add 168fe49be4 Serialize `parquet_options` in `datafusion-proto` (#14465)
add 22a2061259 fix: `List` of `FixedSizeList` coercion issue in SQL
(#14468)
add fe8ab01b29 make datafusion-catalog-listing and move some
implementation of listing out of datafusion/core/datasource/listing (#14464)
add d5ff3e7c24 refactor: remove uses of `arrow_buffer` & `arrow_array` and
use reexport in arrow instead (#14503)
add 61ab9d0e4b core: Support uncorrelated EXISTS (#14474)
add 304488d348 chore(deps): Update sqlparser to `0.54.0` (#14255)
add 5239d1acfa Validate and unpack function arguments tersely (#14513)
add 62e23a2561 bug: Fix edge cases in array_slice (#14489)
add 55730dcece Feat: Add fetch to CoalescePartitionsExec (#14499)
add ad60ffcfca Improve error messages to include the function name.
(#14511)
add 8ebed674dd Script and documentation for regenerating sqlite test files
(#14290)
add 5e1e693b6e Introduce unified `DataSourceExec` for provided
datasources, remove `ParquetExec`, `CsvExec`, etc (#14224)
add d1308f04c1 fix: order by expr rewrite fix (#14486)
add 7fd04a3ed1 fix: rewrite fetch, skip of the Limit node in correct order
(#14496)
add b9fba66cb0 to_unixtime does not support timestamps with a timezone
(#14490)
add bab0f54daa bug: Remove array_slice two arg variant (#14527)
add ab9fc20454 Minor: deprecate unused index mod (#14534)
add 4f6062e81b fix: Capture nullability in `Values` node planning (#14472)
add c234833b22 Fix: Avoid recursive external error wrapping (#14371)
add 46bcb03a14 Fix config_namespace macro symbol usage (#14520)
add 2aad9d2d91 functions: Remove NullHandling from scalar funcs (#14531)
add 479a277e45 Relax physical schema validation (#14519)
add a9fb58ca3a Minor: Update changelog for `45.0.0` and tweak `CHANGELOG`
docs (#14545)
add c0d4ae7fcc polish MemoryStream related code (#14537)
add fc1835dbd1 refactor: switch BooleanBufferBuilder to NullBufferBuilder
in MaybeNullBufferBuilder (#14504)
add 22fb5f7aaf Allow constructing ScalarUDF from shared implementation
(#14541)
add d5f19f3b67 Add `DataFusionError::Collection` to return multiple
`DataFusionError`s (#14439)
add 7ccc6d7c55 some dependency removals and setup for refactor of
`FileScanConfig` (#14543)
add 91c0975c8a Always use `StringViewArray` as output of `substr` (#14498)
add faa8c1bcc7 refactor: remove remaining uses of `arrow_array` and use
reexport in `arrow` instead (#14528)
add edac669481 chore(deps): update getrandom requirement from 0.2.8 to
0.3.1
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 (11c617f19b)
\
N -- N -- N refs/heads/dependabot/cargo/main/getrandom-0.3.1
(edac669481)
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/pull_request_template.md | 2 +-
Cargo.toml | 6 +-
datafusion-cli/Cargo.lock | 83 ++-
datafusion-cli/Cargo.toml | 2 +-
datafusion-cli/src/functions.rs | 20 +-
.../examples/advanced_parquet_index.rs | 92 +--
datafusion-examples/examples/csv_json_opener.rs | 61 +-
datafusion-examples/examples/custom_file_format.rs | 21 +-
.../ffi/ffi_example_table_provider/Cargo.toml | 1 -
.../ffi/ffi_example_table_provider/src/lib.rs | 9 +-
.../examples/parquet_exec_visitor.rs | 28 +-
datafusion-examples/examples/parquet_index.rs | 21 +-
datafusion-examples/examples/remote_catalog.rs | 7 +-
datafusion-examples/examples/simple_udtf.rs | 6 +-
datafusion/{catalog => catalog-listing}/Cargo.toml | 32 +-
.../{catalog => catalog-listing}/LICENSE.txt | 0
datafusion/{catalog => catalog-listing}/NOTICE.txt | 0
datafusion/{common => catalog-listing}/README.md | 8 +-
.../src}/file_groups.rs | 2 +-
.../listing => catalog-listing/src}/helpers.rs | 130 +++-
.../listing => catalog-listing/src}/mod.rs | 14 +-
.../listing => catalog-listing/src}/url.rs | 13 +-
datafusion/common/Cargo.toml | 2 -
datafusion/common/src/cast.rs | 8 +-
datafusion/common/src/column.rs | 10 +-
datafusion/common/src/config.rs | 9 +-
datafusion/common/src/error.rs | 181 ++++-
datafusion/common/src/hash_utils.rs | 5 +-
datafusion/common/src/pyarrow.rs | 3 +-
datafusion/common/src/scalar/mod.rs | 40 +-
datafusion/common/src/test_util.rs | 6 +-
datafusion/common/src/utils/mod.rs | 13 +-
datafusion/common/src/utils/string_utils.rs | 4 +-
datafusion/core/Cargo.toml | 3 +-
datafusion/core/benches/data_utils/mod.rs | 12 +-
datafusion/core/benches/map_query_sql.rs | 2 +-
datafusion/core/benches/physical_plan.rs | 6 +-
datafusion/core/benches/sort.rs | 21 +-
datafusion/core/benches/sql_planner.rs | 2 +-
datafusion/core/benches/sql_query_with_io.rs | 3 +-
datafusion/core/src/datasource/data_source.rs | 70 ++
.../core/src/datasource/file_format/arrow.rs | 27 +-
datafusion/core/src/datasource/file_format/avro.rs | 41 +-
datafusion/core/src/datasource/file_format/csv.rs | 57 +-
datafusion/core/src/datasource/file_format/json.rs | 38 +-
datafusion/core/src/datasource/file_format/mod.rs | 36 +-
.../core/src/datasource/file_format/parquet.rs | 61 +-
.../core/src/datasource/file_format/write/demux.rs | 7 +-
.../core/src/datasource/file_format/write/mod.rs | 2 +-
.../datasource/file_format/write/orchestration.rs | 2 +-
datafusion/core/src/datasource/listing/mod.rs | 259 +------
datafusion/core/src/datasource/listing/table.rs | 42 +-
datafusion/core/src/datasource/memory.rs | 19 +-
datafusion/core/src/datasource/mod.rs | 1 +
.../src/datasource/physical_plan/arrow_file.rs | 184 +++--
.../core/src/datasource/physical_plan/avro.rs | 281 +++++---
.../core/src/datasource/physical_plan/csv.rs | 604 +++++++---------
.../datasource/physical_plan/file_scan_config.rs | 257 ++++++-
.../src/datasource/physical_plan/file_stream.rs | 27 +-
.../core/src/datasource/physical_plan/json.rs | 255 ++++---
.../core/src/datasource/physical_plan/mod.rs | 34 +-
.../physical_plan/parquet/access_plan.rs | 2 +-
.../src/datasource/physical_plan/parquet/mod.rs | 790 ++++++---------------
.../src/datasource/physical_plan/parquet/opener.rs | 2 +-
.../datasource/physical_plan/parquet/row_filter.rs | 4 +-
.../physical_plan/parquet/row_group_filter.rs | 4 +-
.../src/datasource/physical_plan/parquet/source.rs | 592 +++++++++++++++
.../src/datasource/physical_plan/statistics.rs | 2 +-
datafusion/core/src/datasource/schema_adapter.rs | 37 +-
datafusion/core/src/datasource/stream.rs | 2 +-
datafusion/core/src/datasource/view.rs | 5 +-
datafusion/core/src/execution/session_state.rs | 2 +-
datafusion/core/src/lib.rs | 74 +-
datafusion/core/src/physical_planner.rs | 24 +-
datafusion/core/src/schema_equivalence.rs | 84 +++
datafusion/core/src/test/mod.rs | 34 +-
datafusion/core/src/test_util/parquet.rs | 70 +-
.../core/tests/dataframe/dataframe_functions.rs | 3 +-
datafusion/core/tests/dataframe/mod.rs | 28 +-
datafusion/core/tests/execution/logical_plan.rs | 2 +-
datafusion/core/tests/expr_api/mod.rs | 6 +-
datafusion/core/tests/expr_api/simplification.rs | 4 +-
datafusion/core/tests/fuzz_cases/aggregate_fuzz.rs | 36 +-
.../aggregation_fuzzer/context_generator.rs | 2 +-
.../aggregation_fuzzer/data_generator.rs | 4 +-
.../tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs | 2 +-
.../tests/fuzz_cases/aggregation_fuzzer/mod.rs | 2 +-
.../tests/fuzz_cases/distinct_count_string_fuzz.rs | 4 +-
.../core/tests/fuzz_cases/equivalence/utils.rs | 2 +-
datafusion/core/tests/fuzz_cases/join_fuzz.rs | 34 +-
datafusion/core/tests/fuzz_cases/limit_fuzz.rs | 3 +-
datafusion/core/tests/fuzz_cases/merge_fuzz.rs | 7 +-
datafusion/core/tests/fuzz_cases/pruning.rs | 41 +-
datafusion/core/tests/fuzz_cases/sort_fuzz.rs | 10 +-
.../fuzz_cases/sort_preserving_repartition_fuzz.rs | 20 +-
datafusion/core/tests/fuzz_cases/window_fuzz.rs | 42 +-
datafusion/core/tests/macro_hygiene/mod.rs | 16 +
datafusion/core/tests/memory_limit/mod.rs | 55 +-
datafusion/core/tests/parquet/custom_reader.rs | 31 +-
.../core/tests/parquet/external_access_plan.rs | 35 +-
datafusion/core/tests/parquet/file_statistics.rs | 25 +-
datafusion/core/tests/parquet/page_pruning.rs | 22 +-
datafusion/core/tests/parquet/schema_coercion.rs | 36 +-
datafusion/core/tests/parquet/utils.rs | 19 +-
.../tests/{parquet_exec.rs => parquet_config.rs} | 2 +-
.../physical_optimizer/aggregate_statistics.rs | 13 +-
.../combine_partial_final_agg.rs | 12 +-
.../physical_optimizer/enforce_distribution.rs | 430 ++++++-----
.../tests/physical_optimizer/enforce_sorting.rs | 346 +++++----
.../tests/physical_optimizer/limit_pushdown.rs | 20 +-
.../limited_distinct_aggregation.rs | 32 +-
.../physical_optimizer/projection_pushdown.rs | 134 ++--
.../replace_with_order_preserving_variants.rs | 77 +-
.../tests/physical_optimizer/sanity_checker.rs | 22 +-
.../core/tests/physical_optimizer/test_utils.rs | 41 +-
datafusion/core/tests/sql/explain_analyze.rs | 13 +-
datafusion/core/tests/sql/joins.rs | 12 +-
datafusion/core/tests/sql/path_partition.rs | 18 +-
datafusion/core/tests/user_defined/expr_planner.rs | 2 +-
.../tests/user_defined/user_defined_aggregates.rs | 10 +-
.../user_defined/user_defined_scalar_functions.rs | 9 +-
.../user_defined/user_defined_table_functions.rs | 19 +-
.../user_defined/user_defined_window_functions.rs | 20 +-
datafusion/execution/src/memory_pool/mod.rs | 2 +-
datafusion/expr/src/expr_rewriter/order_by.rs | 18 +-
datafusion/expr/src/lib.rs | 4 +-
datafusion/expr/src/logical_plan/builder.rs | 55 +-
datafusion/expr/src/logical_plan/invariants.rs | 45 +-
datafusion/expr/src/logical_plan/plan.rs | 64 +-
datafusion/expr/src/logical_plan/statement.rs | 1 +
datafusion/expr/src/type_coercion/functions.rs | 193 +++--
datafusion/expr/src/udaf.rs | 9 +-
datafusion/expr/src/udf.rs | 28 +-
datafusion/expr/src/udwf.rs | 9 +-
datafusion/ffi/Cargo.toml | 1 -
datafusion/ffi/src/tests/async_provider.rs | 2 +-
datafusion/ffi/src/tests/mod.rs | 2 +-
datafusion/functions-aggregate/Cargo.toml | 1 -
.../functions-aggregate/benches/array_agg.rs | 6 +-
datafusion/functions-aggregate/src/correlation.rs | 4 +-
datafusion/functions-nested/Cargo.toml | 2 -
datafusion/functions-nested/benches/map.rs | 4 +-
datafusion/functions-nested/src/array_has.rs | 7 +-
datafusion/functions-nested/src/cardinality.rs | 2 +-
datafusion/functions-nested/src/concat.rs | 10 +-
datafusion/functions-nested/src/distance.rs | 2 +-
datafusion/functions-nested/src/empty.rs | 2 +-
datafusion/functions-nested/src/except.rs | 5 +-
datafusion/functions-nested/src/extract.rs | 50 +-
datafusion/functions-nested/src/flatten.rs | 4 +-
datafusion/functions-nested/src/length.rs | 2 +-
datafusion/functions-nested/src/make_array.rs | 15 +-
datafusion/functions-nested/src/map.rs | 6 +-
datafusion/functions-nested/src/map_extract.rs | 9 +-
datafusion/functions-nested/src/map_keys.rs | 2 +-
datafusion/functions-nested/src/map_values.rs | 2 +-
datafusion/functions-nested/src/position.rs | 6 +-
datafusion/functions-nested/src/range.rs | 18 +-
datafusion/functions-nested/src/remove.rs | 10 +-
datafusion/functions-nested/src/repeat.rs | 15 +-
datafusion/functions-nested/src/replace.rs | 8 +-
datafusion/functions-nested/src/resize.rs | 11 +-
datafusion/functions-nested/src/reverse.rs | 9 +-
datafusion/functions-nested/src/sort.rs | 4 +-
datafusion/functions-nested/src/string.rs | 8 +-
datafusion/functions-nested/src/utils.rs | 8 +-
datafusion/functions/src/core/arrow_cast.rs | 6 +-
datafusion/functions/src/core/arrowtypeof.rs | 13 +-
datafusion/functions/src/core/getfield.rs | 12 +-
datafusion/functions/src/core/greatest.rs | 2 +-
datafusion/functions/src/core/least.rs | 2 +-
datafusion/functions/src/core/nullif.rs | 13 +-
datafusion/functions/src/core/nvl.rs | 13 +-
datafusion/functions/src/core/nvl2.rs | 60 +-
datafusion/functions/src/core/version.rs | 15 +-
datafusion/functions/src/crypto/basic.rs | 33 +-
datafusion/functions/src/datetime/date_part.rs | 6 +-
datafusion/functions/src/datetime/make_date.rs | 16 +-
datafusion/functions/src/datetime/mod.rs | 2 +-
datafusion/functions/src/datetime/to_char.rs | 16 +-
datafusion/functions/src/datetime/to_unixtime.rs | 6 +-
datafusion/functions/src/lib.rs | 2 +-
datafusion/functions/src/math/abs.rs | 30 +-
datafusion/functions/src/string/common.rs | 5 +-
datafusion/functions/src/strings.rs | 6 +-
datafusion/functions/src/unicode/substr.rs | 120 ++--
datafusion/functions/src/utils.rs | 43 +-
datafusion/optimizer/src/analyzer/type_coercion.rs | 4 +-
.../src/decorrelate_predicate_subquery.rs | 149 +++-
datafusion/physical-expr-common/Cargo.toml | 1 -
datafusion/physical-expr-common/src/binary_map.rs | 8 +-
datafusion/physical-expr/Cargo.toml | 2 -
datafusion/physical-expr/benches/case_when.rs | 2 +-
datafusion/physical-expr/benches/is_null.rs | 3 +-
.../physical-expr/src/expressions/in_list.rs | 2 +-
.../physical-expr/src/expressions/is_not_null.rs | 9 +-
.../physical-expr/src/expressions/is_null.rs | 9 +-
.../physical-expr/src/intervals/cp_solver.rs | 2 +-
datafusion/physical-expr/src/intervals/utils.rs | 2 +-
datafusion/physical-expr/src/planner.rs | 2 +-
datafusion/physical-expr/src/scalar_function.rs | 15 +-
datafusion/physical-expr/src/utils/mod.rs | 2 +-
datafusion/physical-expr/src/window/window_expr.rs | 2 +-
.../physical-optimizer/src/enforce_distribution.rs | 8 +-
.../physical-optimizer/src/limit_pushdown.rs | 9 -
datafusion/physical-plan/Cargo.toml | 2 -
datafusion/physical-plan/benches/spm.rs | 9 +-
.../src/aggregates/group_values/mod.rs | 5 +-
.../group_values/multi_group_by/bytes.rs | 10 +-
.../group_values/multi_group_by/bytes_view.rs | 10 +-
.../aggregates/group_values/multi_group_by/mod.rs | 5 +-
.../group_values/multi_group_by/primitive.rs | 6 +-
.../src/aggregates/group_values/null_builder.rs | 103 +--
.../src/aggregates/group_values/row.rs | 3 +-
.../group_values/single_group_by/bytes.rs | 2 +-
.../group_values/single_group_by/bytes_view.rs | 2 +-
.../group_values/single_group_by/primitive.rs | 9 +-
datafusion/physical-plan/src/aggregates/mod.rs | 53 +-
.../physical-plan/src/aggregates/order/mod.rs | 2 +-
.../physical-plan/src/aggregates/order/partial.rs | 2 +-
.../src/aggregates/topk/hash_table.rs | 11 +-
.../physical-plan/src/aggregates/topk/heap.rs | 9 +-
.../src/aggregates/topk/priority_map.rs | 4 +-
.../physical-plan/src/aggregates/topk_stream.rs | 2 +-
datafusion/physical-plan/src/coalesce/mod.rs | 10 +-
.../physical-plan/src/coalesce_partitions.rs | 50 +-
datafusion/physical-plan/src/common.rs | 2 +-
datafusion/physical-plan/src/display.rs | 2 +-
datafusion/physical-plan/src/execution_plan.rs | 21 +-
datafusion/physical-plan/src/insert.rs | 3 +-
datafusion/physical-plan/src/joins/cross_join.rs | 5 +-
datafusion/physical-plan/src/joins/hash_join.rs | 91 ++-
datafusion/physical-plan/src/joins/mod.rs | 2 +-
.../physical-plan/src/joins/nested_loop_join.rs | 17 +-
.../physical-plan/src/joins/sort_merge_join.rs | 25 +-
.../physical-plan/src/joins/stream_join_utils.rs | 6 +-
.../physical-plan/src/joins/symmetric_hash_join.rs | 3 +-
datafusion/physical-plan/src/joins/test_utils.rs | 21 +-
datafusion/physical-plan/src/joins/utils.rs | 27 +-
datafusion/physical-plan/src/lib.rs | 1 +
datafusion/physical-plan/src/limit.rs | 2 +-
datafusion/physical-plan/src/memory.rs | 584 +++++++++++----
datafusion/physical-plan/src/placeholder_row.rs | 3 +-
datafusion/physical-plan/src/repartition/mod.rs | 52 +-
datafusion/physical-plan/src/sorts/cursor.rs | 11 +-
datafusion/physical-plan/src/sorts/index.rs | 1 +
datafusion/physical-plan/src/sorts/mod.rs | 3 -
datafusion/physical-plan/src/sorts/partial_sort.rs | 26 +-
datafusion/physical-plan/src/sorts/sort.rs | 19 +-
.../src/sorts/sort_preserving_merge.rs | 62 +-
.../physical-plan/src/sorts/streaming_merge.rs | 2 +-
datafusion/physical-plan/src/source.rs | 208 ++++++
datafusion/physical-plan/src/spill.rs | 3 +-
datafusion/physical-plan/src/stream.rs | 31 +-
datafusion/physical-plan/src/test.rs | 17 +-
datafusion/physical-plan/src/topk/mod.rs | 6 +-
datafusion/physical-plan/src/union.rs | 27 +-
datafusion/physical-plan/src/unnest.rs | 11 +-
datafusion/physical-plan/src/values.rs | 14 +-
datafusion/physical-plan/src/visitor.rs | 6 +-
.../src/windows/bounded_window_agg_exec.rs | 21 +-
datafusion/physical-plan/src/work_table.rs | 2 +-
datafusion/proto/proto/datafusion.proto | 2 +
datafusion/proto/src/generated/pbjson.rs | 18 +
datafusion/proto/src/generated/prost.rs | 4 +
datafusion/proto/src/physical_plan/from_proto.rs | 29 +-
datafusion/proto/src/physical_plan/mod.rs | 243 ++++---
.../proto/tests/cases/roundtrip_physical_plan.rs | 73 +-
datafusion/sql/Cargo.toml | 1 -
datafusion/sql/src/expr/identifier.rs | 2 +-
datafusion/sql/src/expr/mod.rs | 224 +++---
datafusion/sql/src/parser.rs | 6 +-
datafusion/sql/src/planner.rs | 9 +-
datafusion/sql/src/relation/join.rs | 23 +-
datafusion/sql/src/select.rs | 14 +-
datafusion/sql/src/set_expr.rs | 23 +-
datafusion/sql/src/statement.rs | 55 +-
datafusion/sql/src/unparser/ast.rs | 1 +
datafusion/sql/src/unparser/dialect.rs | 9 +-
datafusion/sql/src/unparser/expr.rs | 70 +-
datafusion/sql/src/unparser/plan.rs | 10 +-
datafusion/sql/tests/cases/collection.rs | 59 ++
datafusion/sql/tests/cases/mod.rs | 1 +
datafusion/sql/tests/sql_integration.rs | 54 +-
datafusion/sqllogictest/README.md | 7 +
datafusion/sqllogictest/bin/postgres_container.rs | 4 +-
.../{bin => regenerate}/sqllogictests.rs | 225 ++++--
datafusion/sqllogictest/regenerate_sqlite_files.sh | 205 ++++++
.../src/engines/datafusion_engine/error.rs | 2 +-
.../src/engines/datafusion_engine/normalize.rs | 4 +-
.../src/engines/postgres_engine/mod.rs | 14 +-
.../test_files/agg_func_substitute.slt | 6 +-
datafusion/sqllogictest/test_files/aggregate.slt | 63 +-
.../sqllogictest/test_files/aggregates_topk.slt | 10 +-
datafusion/sqllogictest/test_files/array.slt | 43 +-
datafusion/sqllogictest/test_files/arrow_files.slt | 4 +-
datafusion/sqllogictest/test_files/avro.slt | 2 +-
datafusion/sqllogictest/test_files/copy.slt | 4 +-
.../sqllogictest/test_files/count_star_rule.slt | 6 +-
.../test_files/create_external_table.slt | 6 +-
datafusion/sqllogictest/test_files/cse.slt | 22 +-
datafusion/sqllogictest/test_files/csv_files.slt | 2 +-
datafusion/sqllogictest/test_files/cte.slt | 42 +-
datafusion/sqllogictest/test_files/ddl.slt | 2 +-
datafusion/sqllogictest/test_files/dictionary.slt | 6 +-
datafusion/sqllogictest/test_files/distinct_on.slt | 2 +-
datafusion/sqllogictest/test_files/errors.slt | 17 +-
datafusion/sqllogictest/test_files/explain.slt | 80 ++-
datafusion/sqllogictest/test_files/expr.slt | 4 +-
datafusion/sqllogictest/test_files/functions.slt | 16 +-
datafusion/sqllogictest/test_files/group_by.slt | 120 ++--
datafusion/sqllogictest/test_files/identifiers.slt | 8 +-
datafusion/sqllogictest/test_files/insert.slt | 14 +-
.../sqllogictest/test_files/insert_to_external.slt | 14 +-
datafusion/sqllogictest/test_files/interval.slt | 23 +-
datafusion/sqllogictest/test_files/join.slt.part | 30 +-
.../test_files/join_disable_repartition_joins.slt | 8 +-
datafusion/sqllogictest/test_files/joins.slt | 212 +++---
datafusion/sqllogictest/test_files/json.slt | 4 +-
datafusion/sqllogictest/test_files/limit.slt | 27 +-
datafusion/sqllogictest/test_files/map.slt | 2 +-
datafusion/sqllogictest/test_files/math.slt | 6 +-
.../test_files/monotonic_projection_test.slt | 16 +-
datafusion/sqllogictest/test_files/operator.slt | 16 +-
datafusion/sqllogictest/test_files/options.slt | 6 +-
datafusion/sqllogictest/test_files/order.slt | 63 +-
datafusion/sqllogictest/test_files/parquet.slt | 20 +-
.../test_files/parquet_filter_pushdown.slt | 14 +-
.../test_files/parquet_sorted_statistics.slt | 14 +-
datafusion/sqllogictest/test_files/predicates.slt | 14 +-
datafusion/sqllogictest/test_files/projection.slt | 4 +-
datafusion/sqllogictest/test_files/references.slt | 2 +-
datafusion/sqllogictest/test_files/regexp.slt | 4 +-
datafusion/sqllogictest/test_files/repartition.slt | 15 +-
.../sqllogictest/test_files/repartition_scan.slt | 16 +-
datafusion/sqllogictest/test_files/scalar.slt | 6 +-
datafusion/sqllogictest/test_files/select.slt | 54 +-
.../sqllogictest/test_files/sort_merge_join.slt | 4 +-
.../test_files/string/dictionary_utf8.slt | 2 +-
.../test_files/string/large_string.slt | 2 +-
.../test_files/string/string_literal.slt | 13 +-
.../sqllogictest/test_files/string/string_view.slt | 2 +-
datafusion/sqllogictest/test_files/struct.slt | 2 +-
datafusion/sqllogictest/test_files/subquery.slt | 48 +-
.../sqllogictest/test_files/subquery_sort.slt | 10 +-
datafusion/sqllogictest/test_files/timestamps.slt | 10 +
datafusion/sqllogictest/test_files/topk.slt | 2 +-
.../sqllogictest/test_files/tpch/plans/q1.slt.part | 2 +-
.../test_files/tpch/plans/q10.slt.part | 8 +-
.../test_files/tpch/plans/q11.slt.part | 12 +-
.../test_files/tpch/plans/q12.slt.part | 4 +-
.../test_files/tpch/plans/q13.slt.part | 4 +-
.../test_files/tpch/plans/q14.slt.part | 4 +-
.../test_files/tpch/plans/q15.slt.part | 6 +-
.../test_files/tpch/plans/q16.slt.part | 6 +-
.../test_files/tpch/plans/q17.slt.part | 6 +-
.../test_files/tpch/plans/q18.slt.part | 8 +-
.../test_files/tpch/plans/q19.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q2.slt.part | 18 +-
.../test_files/tpch/plans/q20.slt.part | 10 +-
.../test_files/tpch/plans/q21.slt.part | 12 +-
.../test_files/tpch/plans/q22.slt.part | 18 +-
.../sqllogictest/test_files/tpch/plans/q3.slt.part | 6 +-
.../sqllogictest/test_files/tpch/plans/q4.slt.part | 4 +-
.../sqllogictest/test_files/tpch/plans/q5.slt.part | 12 +-
.../sqllogictest/test_files/tpch/plans/q6.slt.part | 2 +-
.../sqllogictest/test_files/tpch/plans/q7.slt.part | 12 +-
.../sqllogictest/test_files/tpch/plans/q8.slt.part | 16 +-
.../sqllogictest/test_files/tpch/plans/q9.slt.part | 12 +-
datafusion/sqllogictest/test_files/union.slt | 97 +--
datafusion/sqllogictest/test_files/unnest.slt | 18 +-
datafusion/sqllogictest/test_files/window.slt | 122 ++--
datafusion/substrait/Cargo.toml | 1 -
datafusion/substrait/src/logical_plan/consumer.rs | 8 +-
datafusion/substrait/src/logical_plan/producer.rs | 3 +-
datafusion/substrait/src/physical_plan/consumer.rs | 7 +-
datafusion/substrait/src/physical_plan/producer.rs | 172 ++---
.../tests/cases/roundtrip_physical_plan.rs | 8 +-
dev/changelog/45.0.0.md | 10 +-
dev/release/README.md | 4 +-
docs/source/contributor-guide/testing.md | 2 +
.../library-user-guide/building-logical-plans.md | 2 +-
.../library-user-guide/custom-table-providers.md | 2 +-
docs/source/user-guide/cli/datasources.md | 22 +-
docs/source/user-guide/explain-usage.md | 48 +-
docs/source/user-guide/sql/explain.md | 4 +-
386 files changed, 7611 insertions(+), 5266 deletions(-)
copy datafusion/{catalog => catalog-listing}/Cargo.toml (67%)
copy datafusion/{catalog => catalog-listing}/LICENSE.txt (100%)
copy datafusion/{catalog => catalog-listing}/NOTICE.txt (100%)
copy datafusion/{common => catalog-listing}/README.md (69%)
rename datafusion/{core/src/datasource/physical_plan =>
catalog-listing/src}/file_groups.rs (99%)
rename datafusion/{core/src/datasource/listing =>
catalog-listing/src}/helpers.rs (91%)
copy datafusion/{core/src/datasource/listing => catalog-listing/src}/mod.rs
(95%)
rename datafusion/{core/src/datasource/listing => catalog-listing/src}/url.rs
(98%)
create mode 100644 datafusion/core/src/datasource/data_source.rs
create mode 100644
datafusion/core/src/datasource/physical_plan/parquet/source.rs
create mode 100644 datafusion/core/src/schema_equivalence.rs
rename datafusion/core/tests/{parquet_exec.rs => parquet_config.rs} (93%)
create mode 100644 datafusion/physical-plan/src/source.rs
create mode 100644 datafusion/sql/tests/cases/collection.rs
copy datafusion/sqllogictest/{bin => regenerate}/sqllogictests.rs (76%)
create mode 100755 datafusion/sqllogictest/regenerate_sqlite_files.sh
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
