You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ag...@apache.org on 2021/04/18 16:08:19 UTC
[arrow-datafusion] branch master updated (e023b4c -> 0d5f00a)
This is an automated email from the ASF dual-hosted git repository.
agrove pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git.
omit e023b4c Update paths to arrow and parquet test data
omit a1fe501 Add parquet-testing submodule
omit eb2f8cc Remove submodule
omit dfc2120 Fiddle path to flight protobuf generation.
omit 70ac63d Flatten directory.
omit 3fccc96 Removed unused files.
omit 5bc0a1c Removed DataFusion and Ballista.
omit 1176736 Changed references to DF and Ballista in Cargo.
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/master (0d5f00a)
\
O -- O -- O (e023b4c)
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:
.../pyproject.toml => .clang-format | 8 +-
.clang-tidy | 31 +
.../pyproject.toml => .clang-tidy-ignore | 6 +-
.dir-locals.el | 22 +
.dockerignore | 3 +
.env | 74 +
.github/workflows/cpp.yml | 395 +
.github/workflows/cpp_cron.yml | 149 +
.github/workflows/csharp.yml | 121 +
.github/workflows/dev_pr/labeler.yml | 6 +
.github/workflows/go.yml | 125 +
.github/workflows/java.yml | 112 +
.github/workflows/java_jni.yml | 83 +
.github/workflows/js.yml | 122 +
.github/workflows/julia.yml | 53 +
.github/workflows/python.yml | 154 +
.github/workflows/python_cron.yml | 141 +
.github/workflows/r.yml | 255 +
.github/workflows/ruby.yml | 290 +
.gitignore | 87 +-
.gitmodules | 6 +-
rustfmt.toml => .hadolint.yaml | 14 +-
.../pyproject.toml => .readthedocs.yml | 5 +-
.travis.yml | 165 +
README.md | 254 +-
appveyor.yml | 79 +
cmake-format.py | 59 +
parquet-testing | 1 -
run-cmake-format.py | 111 +
.gitignore => rust/.gitignore | 0
Cargo.toml => rust/Cargo.toml | 5 +-
README.md => rust/README.md | 0
{arrow-flight => rust/arrow-flight}/Cargo.toml | 0
{arrow-flight => rust/arrow-flight}/README.md | 0
{arrow-flight => rust/arrow-flight}/build.rs | 6 +-
.../arrow-flight}/examples/server.rs | 0
.../arrow-flight}/src/arrow.flight.protocol.rs | 0
{arrow-flight => rust/arrow-flight}/src/lib.rs | 0
{arrow-flight => rust/arrow-flight}/src/utils.rs | 0
.../.cargo/config | 0
.../arrow-pyarrow-integration-testing}/.gitignore | 0
.../arrow-pyarrow-integration-testing}/Cargo.toml | 0
.../arrow-pyarrow-integration-testing}/README.md | 0
.../pyproject.toml | 0
.../arrow-pyarrow-integration-testing}/src/lib.rs | 0
.../tests/test_sql.py | 0
{arrow => rust/arrow}/Cargo.toml | 0
{arrow => rust/arrow}/README.md | 0
{arrow => rust/arrow}/benches/aggregate_kernels.rs | 0
.../arrow}/benches/arithmetic_kernels.rs | 0
{arrow => rust/arrow}/benches/array_from_vec.rs | 0
{arrow => rust/arrow}/benches/array_slice.rs | 0
{arrow => rust/arrow}/benches/bit_length_kernel.rs | 0
{arrow => rust/arrow}/benches/boolean_kernels.rs | 0
{arrow => rust/arrow}/benches/buffer_bit_ops.rs | 0
{arrow => rust/arrow}/benches/buffer_create.rs | 0
{arrow => rust/arrow}/benches/builder.rs | 0
{arrow => rust/arrow}/benches/cast_kernels.rs | 0
.../arrow}/benches/comparison_kernels.rs | 0
.../arrow}/benches/concatenate_kernel.rs | 0
{arrow => rust/arrow}/benches/csv_writer.rs | 0
{arrow => rust/arrow}/benches/equal.rs | 0
{arrow => rust/arrow}/benches/filter_kernels.rs | 0
{arrow => rust/arrow}/benches/json_reader.rs | 0
{arrow => rust/arrow}/benches/length_kernel.rs | 0
{arrow => rust/arrow}/benches/mutable_array.rs | 0
{arrow => rust/arrow}/benches/sort_kernel.rs | 0
{arrow => rust/arrow}/benches/take_kernels.rs | 0
{arrow => rust/arrow}/build.rs | 0
{arrow => rust/arrow}/examples/builders.rs | 0
{arrow => rust/arrow}/examples/dynamic_types.rs | 0
{arrow => rust/arrow}/examples/read_csv.rs | 0
.../arrow}/examples/read_csv_infer_schema.rs | 0
{arrow => rust/arrow}/examples/tensor_builder.rs | 0
{arrow => rust/arrow}/format-0ed34c83.patch | 0
{arrow => rust/arrow}/regen.sh | 0
{arrow => rust/arrow}/src/alloc/alignment.rs | 0
{arrow => rust/arrow}/src/alloc/mod.rs | 0
{arrow => rust/arrow}/src/alloc/types.rs | 0
{arrow => rust/arrow}/src/arch/avx512.rs | 0
{arrow => rust/arrow}/src/arch/mod.rs | 0
{arrow => rust/arrow}/src/array/array.rs | 0
{arrow => rust/arrow}/src/array/array_binary.rs | 0
{arrow => rust/arrow}/src/array/array_boolean.rs | 0
.../arrow}/src/array/array_dictionary.rs | 0
{arrow => rust/arrow}/src/array/array_list.rs | 0
{arrow => rust/arrow}/src/array/array_primitive.rs | 0
{arrow => rust/arrow}/src/array/array_string.rs | 0
{arrow => rust/arrow}/src/array/array_struct.rs | 0
{arrow => rust/arrow}/src/array/array_union.rs | 0
{arrow => rust/arrow}/src/array/builder.rs | 0
{arrow => rust/arrow}/src/array/cast.rs | 0
{arrow => rust/arrow}/src/array/data.rs | 0
{arrow => rust/arrow}/src/array/equal/boolean.rs | 0
{arrow => rust/arrow}/src/array/equal/decimal.rs | 0
.../arrow}/src/array/equal/dictionary.rs | 0
.../arrow}/src/array/equal/fixed_binary.rs | 0
.../arrow}/src/array/equal/fixed_list.rs | 0
{arrow => rust/arrow}/src/array/equal/list.rs | 0
{arrow => rust/arrow}/src/array/equal/mod.rs | 0
{arrow => rust/arrow}/src/array/equal/null.rs | 0
{arrow => rust/arrow}/src/array/equal/primitive.rs | 0
{arrow => rust/arrow}/src/array/equal/structure.rs | 0
{arrow => rust/arrow}/src/array/equal/utils.rs | 0
.../arrow}/src/array/equal/variable_size.rs | 0
{arrow => rust/arrow}/src/array/equal_json.rs | 0
{arrow => rust/arrow}/src/array/ffi.rs | 0
{arrow => rust/arrow}/src/array/iterator.rs | 0
{arrow => rust/arrow}/src/array/mod.rs | 0
{arrow => rust/arrow}/src/array/null.rs | 0
{arrow => rust/arrow}/src/array/ord.rs | 0
{arrow => rust/arrow}/src/array/raw_pointer.rs | 0
.../arrow}/src/array/transform/boolean.rs | 0
.../arrow}/src/array/transform/fixed_binary.rs | 0
{arrow => rust/arrow}/src/array/transform/list.rs | 0
{arrow => rust/arrow}/src/array/transform/mod.rs | 0
{arrow => rust/arrow}/src/array/transform/null.rs | 0
.../arrow}/src/array/transform/primitive.rs | 0
.../arrow}/src/array/transform/structure.rs | 0
{arrow => rust/arrow}/src/array/transform/utils.rs | 0
.../arrow}/src/array/transform/variable_size.rs | 0
{arrow => rust/arrow}/src/bitmap.rs | 0
{arrow => rust/arrow}/src/buffer/immutable.rs | 0
{arrow => rust/arrow}/src/buffer/mod.rs | 0
{arrow => rust/arrow}/src/buffer/mutable.rs | 0
{arrow => rust/arrow}/src/buffer/ops.rs | 0
{arrow => rust/arrow}/src/bytes.rs | 0
.../arrow}/src/compute/kernels/aggregate.rs | 0
.../arrow}/src/compute/kernels/arithmetic.rs | 0
{arrow => rust/arrow}/src/compute/kernels/arity.rs | 0
.../arrow}/src/compute/kernels/boolean.rs | 0
{arrow => rust/arrow}/src/compute/kernels/cast.rs | 0
.../arrow}/src/compute/kernels/cast_utils.rs | 0
.../arrow}/src/compute/kernels/comparison.rs | 0
.../arrow}/src/compute/kernels/concat.rs | 0
.../arrow}/src/compute/kernels/filter.rs | 0
.../arrow}/src/compute/kernels/length.rs | 0
{arrow => rust/arrow}/src/compute/kernels/limit.rs | 0
{arrow => rust/arrow}/src/compute/kernels/mod.rs | 0
.../arrow}/src/compute/kernels/regexp.rs | 0
{arrow => rust/arrow}/src/compute/kernels/sort.rs | 0
.../arrow}/src/compute/kernels/substring.rs | 0
{arrow => rust/arrow}/src/compute/kernels/take.rs | 0
.../arrow}/src/compute/kernels/temporal.rs | 0
.../arrow}/src/compute/kernels/window.rs | 0
{arrow => rust/arrow}/src/compute/kernels/zip.rs | 0
{arrow => rust/arrow}/src/compute/mod.rs | 0
{arrow => rust/arrow}/src/compute/util.rs | 0
{arrow => rust/arrow}/src/csv/mod.rs | 0
{arrow => rust/arrow}/src/csv/reader.rs | 0
{arrow => rust/arrow}/src/csv/writer.rs | 0
{arrow => rust/arrow}/src/datatypes/datatype.rs | 0
{arrow => rust/arrow}/src/datatypes/field.rs | 0
{arrow => rust/arrow}/src/datatypes/mod.rs | 0
{arrow => rust/arrow}/src/datatypes/native.rs | 0
{arrow => rust/arrow}/src/datatypes/numeric.rs | 0
{arrow => rust/arrow}/src/datatypes/schema.rs | 0
{arrow => rust/arrow}/src/datatypes/types.rs | 0
{arrow => rust/arrow}/src/error.rs | 0
{arrow => rust/arrow}/src/ffi.rs | 0
{arrow => rust/arrow}/src/ipc/convert.rs | 0
{arrow => rust/arrow}/src/ipc/gen/File.rs | 0
{arrow => rust/arrow}/src/ipc/gen/Message.rs | 0
{arrow => rust/arrow}/src/ipc/gen/Schema.rs | 0
{arrow => rust/arrow}/src/ipc/gen/SparseTensor.rs | 0
{arrow => rust/arrow}/src/ipc/gen/Tensor.rs | 0
{arrow => rust/arrow}/src/ipc/gen/mod.rs | 0
{arrow => rust/arrow}/src/ipc/mod.rs | 0
{arrow => rust/arrow}/src/ipc/reader.rs | 0
{arrow => rust/arrow}/src/ipc/writer.rs | 0
{arrow => rust/arrow}/src/json/mod.rs | 0
{arrow => rust/arrow}/src/json/reader.rs | 0
{arrow => rust/arrow}/src/json/writer.rs | 0
{arrow => rust/arrow}/src/lib.rs | 0
{arrow => rust/arrow}/src/record_batch.rs | 0
{arrow => rust/arrow}/src/temporal_conversions.rs | 0
{arrow => rust/arrow}/src/tensor.rs | 0
{arrow => rust/arrow}/src/util/bench_util.rs | 0
.../arrow}/src/util/bit_chunk_iterator.rs | 0
{arrow => rust/arrow}/src/util/bit_util.rs | 0
{arrow => rust/arrow}/src/util/data_gen.rs | 0
{arrow => rust/arrow}/src/util/display.rs | 0
{arrow => rust/arrow}/src/util/integration_util.rs | 0
{arrow => rust/arrow}/src/util/mod.rs | 0
{arrow => rust/arrow}/src/util/pretty.rs | 0
{arrow => rust/arrow}/src/util/serialization.rs | 0
{arrow => rust/arrow}/src/util/string_writer.rs | 0
{arrow => rust/arrow}/src/util/test_util.rs | 4 +-
{arrow => rust/arrow}/src/util/trusted_len.rs | 0
{arrow => rust/arrow}/src/zz_memory_check.rs | 0
{arrow => rust/arrow}/test/data/arrays.json | 0
{arrow => rust/arrow}/test/data/basic.json | 0
{arrow => rust/arrow}/test/data/basic_nulls.json | 0
{arrow => rust/arrow}/test/data/integration.json | 0
.../arrow}/test/data/list_string_dict_nested.json | 0
.../test/data/list_string_dict_nested_nulls.json | 0
{arrow => rust/arrow}/test/data/mixed_arrays.json | 0
.../arrow}/test/data/mixed_arrays.json.gz | Bin
.../arrow}/test/data/nested_structs.json | 0
{arrow => rust/arrow}/test/data/null_test.csv | 0
{arrow => rust/arrow}/test/data/uk_cities.csv | 0
.../arrow}/test/data/uk_cities_with_headers.csv | 0
{arrow => rust/arrow}/test/data/various_types.csv | 0
.../arrow}/test/data/various_types_invalid.csv | 0
.../pyproject.toml => rust/ballista/.dockerignore | 4 +-
rust/ballista/README.md | 64 +
.../ballista/dev/build-rust-base.sh | 13 +-
rustfmt.toml => rust/ballista/dev/build-rust.sh | 12 +-
.../ballista/dev/integration-tests.sh | 16 +-
.../ballista/docker}/README.md | 15 +-
rust/ballista/docker/rust-base.dockerfile | 99 +
rust/ballista/docker/rust.dockerfile | 71 +
.../ballista/docs}/README.md | 23 +-
rust/ballista/docs/architecture.md | 75 +
.../ballista/docs/dev-env-rust.md | 24 +-
rust/ballista/docs/images/query-execution.png | Bin 0 -> 11378 bytes
.../ballista/docs/integration-testing.md | 18 +-
rust/ballista/docs/release-process.md | 68 +
rust/ballista/docs/rust-docker.md | 66 +
rust/ballista/docs/user-guide/.gitignore | 2 +
.../ballista/docs/user-guide}/README.md | 22 +-
.../ballista/docs/user-guide/book.toml | 13 +-
.../ballista/docs/user-guide/src/SUMMARY.md | 22 +-
.../ballista/docs/user-guide/src/client-rust.md | 14 +-
.../ballista/docs/user-guide/src/clients.md | 14 +-
rust/ballista/docs/user-guide/src/configuration.md | 32 +
.../ballista/docs/user-guide/src/deployment.md | 14 +-
.../ballista/docs/user-guide/src/docker-compose.md | 55 +
.../ballista/docs/user-guide/src/faq.md | 17 +-
.../user-guide/src/img/ballista-architecture.png | Bin 0 -> 21225 bytes
rust/ballista/docs/user-guide/src/introduction.md | 52 +
rust/ballista/docs/user-guide/src/kubernetes.md | 216 +
rust/ballista/docs/user-guide/src/standalone.md | 92 +
.../ballista/rust/.dockerignore | 9 +-
rust/ballista/rust/.gitignore | 2 +
rustfmt.toml => rust/ballista/rust/Cargo.toml | 18 +-
.../ballista/rust/benchmarks/tpch/.dockerignore | 13 +-
rust/ballista/rust/benchmarks/tpch/.gitignore | 1 +
.../ballista/rust/benchmarks/tpch}/Cargo.toml | 20 +-
rust/ballista/rust/benchmarks/tpch/README.md | 104 +
.../rust/benchmarks/tpch/docker-compose.yaml | 62 +
.../ballista/rust/benchmarks/tpch/entrypoint.sh | 8 +-
rust/ballista/rust/benchmarks/tpch/queries/q1.sql | 21 +
rust/ballista/rust/benchmarks/tpch/queries/q10.sql | 31 +
rust/ballista/rust/benchmarks/tpch/queries/q11.sql | 27 +
rust/ballista/rust/benchmarks/tpch/queries/q12.sql | 30 +
rust/ballista/rust/benchmarks/tpch/queries/q13.sql | 20 +
rust/ballista/rust/benchmarks/tpch/queries/q14.sql | 13 +
rust/ballista/rust/benchmarks/tpch/queries/q16.sql | 30 +
rust/ballista/rust/benchmarks/tpch/queries/q17.sql | 17 +
rust/ballista/rust/benchmarks/tpch/queries/q18.sql | 32 +
rust/ballista/rust/benchmarks/tpch/queries/q19.sql | 35 +
rust/ballista/rust/benchmarks/tpch/queries/q2.sql | 43 +
rust/ballista/rust/benchmarks/tpch/queries/q20.sql | 37 +
rust/ballista/rust/benchmarks/tpch/queries/q21.sql | 39 +
rust/ballista/rust/benchmarks/tpch/queries/q22.sql | 37 +
rust/ballista/rust/benchmarks/tpch/queries/q3.sql | 22 +
rust/ballista/rust/benchmarks/tpch/queries/q4.sql | 21 +
rust/ballista/rust/benchmarks/tpch/queries/q5.sql | 24 +
rust/ballista/rust/benchmarks/tpch/queries/q6.sql | 9 +
rust/ballista/rust/benchmarks/tpch/queries/q7.sql | 39 +
rust/ballista/rust/benchmarks/tpch/queries/q8.sql | 37 +
rust/ballista/rust/benchmarks/tpch/queries/q9.sql | 32 +
.../ballista/rust/benchmarks/tpch/run.sh | 13 +-
rust/ballista/rust/benchmarks/tpch/src/main.rs | 360 +
.../ballista/rust/benchmarks/tpch/tpch-gen.sh | 21 +-
.../rust/benchmarks/tpch/tpchgen.dockerfile | 20 +-
.../ballista/rust/client}/Cargo.toml | 17 +-
.../ballista/rust/client}/README.md | 12 +-
rust/ballista/rust/client/src/columnar_batch.rs | 167 +
rust/ballista/rust/client/src/context.rs | 400 +
.../ballista/rust/client}/src/lib.rs | 6 +-
.../ballista/rust/client/src/prelude.rs | 7 +-
.../ballista/rust/core}/Cargo.toml | 45 +-
.../ballista/rust/core}/README.md | 13 +-
{arrow => rust/ballista/rust/core}/build.rs | 14 +-
rust/ballista/rust/core/proto/ballista.proto | 824 ++
rust/ballista/rust/core/src/client.rs | 224 +
rust/ballista/rust/core/src/datasource.rs | 72 +
rust/ballista/rust/core/src/error.rs | 172 +
.../ballista/rust/core/src/execution_plans}/mod.rs | 16 +-
.../rust/core/src/execution_plans/query_stage.rs | 92 +
.../core/src/execution_plans/shuffle_reader.rs | 106 +
.../core/src/execution_plans/unresolved_shuffle.rs | 101 +
.../ballista/rust/core}/src/lib.rs | 16 +-
rust/ballista/rust/core/src/memory_stream.rs | 93 +
.../rust/core/src/serde/logical_plan/from_proto.rs | 1200 ++
.../rust/core/src/serde/logical_plan/mod.rs | 929 ++
.../rust/core/src/serde/logical_plan/to_proto.rs | 1233 ++
rust/ballista/rust/core/src/serde/mod.rs | 69 +
.../core/src/serde/physical_plan/from_proto.rs | 398 +
.../rust/core/src/serde/physical_plan/mod.rs | 178 +
.../rust/core/src/serde/physical_plan/to_proto.rs | 556 +
.../rust/core/src/serde/scheduler/from_proto.rs | 124 +
rust/ballista/rust/core/src/serde/scheduler/mod.rs | 262 +
.../rust/core/src/serde/scheduler/to_proto.rs | 90 +
rust/ballista/rust/core/src/utils.rs | 327 +
.../ballista/rust/executor}/Cargo.toml | 46 +-
.../ballista/rust/executor}/README.md | 17 +-
{arrow => rust/ballista/rust/executor}/build.rs | 12 +-
.../executor/examples/example_executor_config.toml | 10 +-
.../rust/executor/executor_config_spec.toml | 79 +
rust/ballista/rust/executor/src/collect.rs | 127 +
rust/ballista/rust/executor/src/execution_loop.rs | 172 +
rust/ballista/rust/executor/src/flight_service.rs | 374 +
.../ballista/rust/executor/src/lib.rs | 40 +-
rust/ballista/rust/executor/src/main.rs | 176 +
.../ballista/rust/scheduler}/Cargo.toml | 53 +-
rust/ballista/rust/scheduler/README.md | 51 +
{arrow => rust/ballista/rust/scheduler}/build.rs | 12 +-
.../rust/scheduler/scheduler_config_spec.toml | 60 +
rust/ballista/rust/scheduler/src/api/handlers.rs | 55 +
rust/ballista/rust/scheduler/src/api/mod.rs | 87 +
rust/ballista/rust/scheduler/src/lib.rs | 490 +
rust/ballista/rust/scheduler/src/main.rs | 156 +
rust/ballista/rust/scheduler/src/planner.rs | 494 +
rust/ballista/rust/scheduler/src/state/etcd.rs | 205 +
rust/ballista/rust/scheduler/src/state/mod.rs | 880 ++
.../rust/scheduler/src/state/standalone.rs | 228 +
rust/ballista/rust/scheduler/src/test_utils.rs | 148 +
.../rust/scheduler/testdata/customer/customer.tbl | 10 +
.../scheduler/testdata/lineitem/partition0.tbl | 10 +
.../scheduler/testdata/lineitem/partition1.tbl | 10 +
.../rust/scheduler/testdata/nation/nation.tbl | 10 +
.../rust/scheduler/testdata/orders/orders.tbl | 10 +
.../ballista/rust/scheduler/testdata/part/part.tbl | 10 +
.../rust/scheduler/testdata/partsupp/partsupp.tbl | 10 +
.../rust/scheduler/testdata/region/region.tbl | 5 +
.../rust/scheduler/testdata/supplier/supplier.tbl | 10 +
rust/ballista/ui/scheduler/.gitignore | 23 +
.../ballista/ui/scheduler}/README.md | 31 +-
.../ballista/ui/scheduler/index.d.ts | 4 +-
rust/ballista/ui/scheduler/package.json | 58 +
rust/ballista/ui/scheduler/public/favicon.ico | Bin 0 -> 3870 bytes
rust/ballista/ui/scheduler/public/index.html | 62 +
rust/ballista/ui/scheduler/public/logo192.png | Bin 0 -> 5347 bytes
rust/ballista/ui/scheduler/public/logo512.png | Bin 0 -> 9664 bytes
rust/ballista/ui/scheduler/public/manifest.json | 25 +
.../ballista/ui/scheduler/public/robots.txt | 6 +-
rust/ballista/ui/scheduler/react-table-config.d.ts | 137 +
.../ballista/ui/scheduler/src/App.css | 16 +-
.../ballista/ui/scheduler/src/App.test.tsx | 10 +-
rust/ballista/ui/scheduler/src/App.tsx | 97 +
.../ui/scheduler/src/components/DataTable.tsx | 131 +
.../ballista/ui/scheduler/src/components/Empty.tsx | 26 +-
.../ui/scheduler/src/components/Footer.tsx | 17 +-
.../ui/scheduler/src/components/Header.tsx | 82 +
.../ui/scheduler/src/components/NodesList.tsx | 71 +
.../ui/scheduler/src/components/QueriesList.tsx | 115 +
.../ui/scheduler/src/components/Summary.tsx | 89 +
rust/ballista/ui/scheduler/src/components/logo.svg | 25 +
.../ballista/ui/scheduler/src/index.css | 24 +-
.../ballista/ui/scheduler/src/index.tsx | 32 +-
.../ballista/ui/scheduler/src/react-app-env.d.ts | 4 +-
.../ballista/ui/scheduler/src/reportWebVitals.ts | 22 +-
.../ballista/ui/scheduler/src/setupTests.ts | 8 +-
rust/ballista/ui/scheduler/tsconfig.json | 28 +
rust/ballista/ui/scheduler/yarn.lock | 12431 +++++++++++++++++++
.../benchmarks}/Cargo.toml | 29 +-
rust/benchmarks/README.md | 120 +
rust/benchmarks/src/bin/nyctaxi.rs | 151 +
rust/benchmarks/src/bin/tpch.rs | 1692 +++
.../datafusion-examples}/Cargo.toml | 24 +-
.../datafusion-examples/examples}/README.md | 14 +-
rust/datafusion-examples/examples/csv_sql.rs | 52 +
rust/datafusion-examples/examples/dataframe.rs | 47 +
.../examples/dataframe_in_memory.rs | 67 +
rust/datafusion-examples/examples/flight_client.rs | 79 +
.../datafusion-examples/examples/flight_server.rs | 112 +-
rust/datafusion-examples/examples/parquet_sql.rs | 50 +
rust/datafusion-examples/examples/simple_udaf.rs | 170 +
rust/datafusion-examples/examples/simple_udf.rs | 151 +
rust/datafusion/Cargo.toml | 99 +
rust/datafusion/DEVELOPERS.md | 92 +
rustfmt.toml => rust/datafusion/Dockerfile | 13 +-
rust/datafusion/README.md | 356 +
rust/datafusion/benches/aggregate_query_sql.rs | 248 +
rust/datafusion/benches/filter_query_sql.rs | 91 +
rust/datafusion/benches/math_query_sql.rs | 111 +
.../null.rs => rust/datafusion/benches/scalar.rs | 14 +-
rust/datafusion/benches/sort_limit_query_sql.rs | 148 +
rust/datafusion/docs/cli.md | 95 +
.../docs/images/DataFusion-Logo-Dark.png | Bin 0 -> 20134 bytes
.../docs/images/DataFusion-Logo-Dark.svg | 1 +
.../docs/images/DataFusion-Logo-Light.png | Bin 0 -> 19102 bytes
.../docs/images/DataFusion-Logo-Light.svg | 1 +
.../src/lib.rs => rust/datafusion/src/bin/main.rs | 9 +-
rust/datafusion/src/bin/repl.rs | 140 +
rust/datafusion/src/catalog/catalog.rs | 139 +
rust/datafusion/src/catalog/information_schema.rs | 492 +
rust/datafusion/src/catalog/mod.rs | 146 +
rust/datafusion/src/catalog/schema.rs | 104 +
rust/datafusion/src/dataframe.rs | 286 +
rust/datafusion/src/datasource/csv.rs | 144 +
rust/datafusion/src/datasource/datasource.rs | 103 +
rust/datafusion/src/datasource/empty.rs | 80 +
rust/datafusion/src/datasource/memory.rs | 472 +
.../util => rust/datafusion/src/datasource}/mod.rs | 17 +-
rust/datafusion/src/datasource/parquet.rs | 373 +
rust/datafusion/src/error.rs | 120 +
rust/datafusion/src/execution/context.rs | 3123 +++++
rust/datafusion/src/execution/dataframe_impl.rs | 374 +
.../lib.rs => rust/datafusion/src/execution/mod.rs | 5 +-
rust/datafusion/src/lib.rs | 211 +
rust/datafusion/src/logical_plan/builder.rs | 595 +
rust/datafusion/src/logical_plan/dfschema.rs | 521 +
rust/datafusion/src/logical_plan/display.rs | 270 +
rust/datafusion/src/logical_plan/expr.rs | 1505 +++
rust/datafusion/src/logical_plan/extension.rs | 79 +
rust/datafusion/src/logical_plan/mod.rs | 50 +
rust/datafusion/src/logical_plan/operators.rs | 135 +
rust/datafusion/src/logical_plan/plan.rs | 1095 ++
.../datafusion/src/logical_plan/registry.rs | 24 +-
rust/datafusion/src/optimizer/constant_folding.rs | 591 +
rust/datafusion/src/optimizer/filter_push_down.rs | 1021 ++
.../src/optimizer/hash_build_probe_order.rs | 257 +
rust/datafusion/src/optimizer/limit_push_down.rs | 252 +
.../lib.rs => rust/datafusion/src/optimizer/mod.rs | 9 +-
.../datafusion/src/optimizer/optimizer.rs | 24 +-
.../src/optimizer/projection_push_down.rs | 542 +
rust/datafusion/src/optimizer/utils.rs | 489 +
.../src/physical_optimizer/coalesce_batches.rs | 88 +
.../src/physical_optimizer/merge_exec.rs | 74 +
.../datafusion/src/physical_optimizer}/mod.rs | 15 +-
.../datafusion/src/physical_optimizer/optimizer.rs | 25 +-
.../src/physical_optimizer/repartition.rs | 186 +
rust/datafusion/src/physical_plan/aggregates.rs | 258 +
.../src/physical_plan/array_expressions.rs | 127 +
.../src/physical_plan/coalesce_batches.rs | 316 +
rust/datafusion/src/physical_plan/common.rs | 104 +
.../src/physical_plan/crypto_expressions.rs | 198 +
rust/datafusion/src/physical_plan/csv.rs | 401 +
.../src/physical_plan/datetime_expressions.rs | 559 +
.../src/physical_plan/distinct_expressions.rs | 557 +
rust/datafusion/src/physical_plan/empty.rs | 186 +
rust/datafusion/src/physical_plan/explain.rs | 125 +
.../src/physical_plan/expressions/average.rs | 293 +
.../src/physical_plan/expressions/binary.rs | 1101 ++
.../src/physical_plan/expressions/case.rs | 597 +
.../src/physical_plan/expressions/cast.rs | 301 +
.../src/physical_plan/expressions/coercion.rs | 208 +
.../src/physical_plan/expressions/column.rs | 86 +
.../src/physical_plan/expressions/count.rs | 235 +
.../src/physical_plan/expressions/in_list.rs | 458 +
.../src/physical_plan/expressions/is_not_null.rs | 119 +
.../src/physical_plan/expressions/is_null.rs | 119 +
.../src/physical_plan/expressions/literal.rs | 108 +
.../src/physical_plan/expressions/min_max.rs | 655 +
.../src/physical_plan/expressions/mod.rs | 135 +
.../src/physical_plan/expressions/negative.rs | 133 +
.../src/physical_plan/expressions/not.rs | 158 +
.../src/physical_plan/expressions/nullif.rs | 188 +
.../src/physical_plan/expressions/sum.rs | 373 +
.../src/physical_plan/expressions/try_cast.rs | 247 +
rust/datafusion/src/physical_plan/filter.rs | 240 +
rust/datafusion/src/physical_plan/functions.rs | 3767 ++++++
rust/datafusion/src/physical_plan/group_scalar.rs | 212 +
.../datafusion/src/physical_plan/hash_aggregate.rs | 1395 +++
rust/datafusion/src/physical_plan/hash_join.rs | 1265 ++
rust/datafusion/src/physical_plan/hash_utils.rs | 201 +
rust/datafusion/src/physical_plan/limit.rs | 338 +
.../src/physical_plan/math_expressions.rs | 118 +
rust/datafusion/src/physical_plan/memory.rs | 161 +
rust/datafusion/src/physical_plan/merge.rs | 225 +
rust/datafusion/src/physical_plan/mod.rs | 369 +
rust/datafusion/src/physical_plan/parquet.rs | 1535 +++
rust/datafusion/src/physical_plan/planner.rs | 1106 ++
rust/datafusion/src/physical_plan/projection.rs | 232 +
.../src/physical_plan/regex_expressions.rs | 172 +
rust/datafusion/src/physical_plan/repartition.rs | 461 +
rust/datafusion/src/physical_plan/sort.rs | 478 +
.../src/physical_plan/string_expressions.rs | 595 +
rust/datafusion/src/physical_plan/type_coercion.rs | 361 +
rust/datafusion/src/physical_plan/udaf.rs | 168 +
rust/datafusion/src/physical_plan/udf.rs | 112 +
.../src/physical_plan/unicode_expressions.rs | 532 +
rust/datafusion/src/physical_plan/union.rs | 143 +
rust/datafusion/src/prelude.rs | 37 +
rust/datafusion/src/scalar.rs | 821 ++
.../src/util => rust/datafusion/src/sql}/mod.rs | 14 +-
rust/datafusion/src/sql/parser.rs | 380 +
rust/datafusion/src/sql/planner.rs | 2723 ++++
rust/datafusion/src/sql/utils.rs | 376 +
rust/datafusion/src/test/exec.rs | 102 +
rust/datafusion/src/test/mod.rs | 346 +
rust/datafusion/src/test/user_defined.rs | 76 +
rust/datafusion/src/test/variable.rs | 58 +
.../datafusion/src/variable/mod.rs | 28 +-
rust/datafusion/tests/aggregate_simple.csv | 16 +
rust/datafusion/tests/custom_sources.rs | 200 +
rust/datafusion/tests/customer.csv | 4 +
rust/datafusion/tests/dataframe.rs | 79 +
rust/datafusion/tests/example.csv | 2 +
rust/datafusion/tests/provider_filter_pushdown.rs | 177 +
rust/datafusion/tests/sql.rs | 2707 ++++
rust/datafusion/tests/user_defined_plan.rs | 512 +
.../integration-testing}/Cargo.toml | 0
.../integration-testing}/README.md | 0
.../src/bin/arrow-file-to-stream.rs | 0
.../src/bin/arrow-json-integration-test.rs | 0
.../src/bin/arrow-stream-to-file.rs | 0
.../src/bin/flight-test-integration-client.rs | 0
.../src/bin/flight-test-integration-server.rs | 0
.../src/flight_client_scenarios.rs | 0
.../flight_client_scenarios/auth_basic_proto.rs | 0
.../flight_client_scenarios/integration_test.rs | 0
.../src/flight_client_scenarios/middleware.rs | 0
.../src/flight_server_scenarios.rs | 0
.../flight_server_scenarios/auth_basic_proto.rs | 0
.../flight_server_scenarios/integration_test.rs | 0
.../src/flight_server_scenarios/middleware.rs | 0
.../integration-testing}/src/lib.rs | 0
{parquet => rust/parquet}/Cargo.toml | 0
{parquet => rust/parquet}/README.md | 0
{parquet => rust/parquet}/benches/arrow_writer.rs | 0
{parquet => rust/parquet}/build.rs | 0
.../parquet}/src/arrow/array_reader.rs | 0
.../parquet}/src/arrow/arrow_reader.rs | 0
.../parquet}/src/arrow/arrow_writer.rs | 0
{parquet => rust/parquet}/src/arrow/converter.rs | 0
{parquet => rust/parquet}/src/arrow/levels.rs | 0
{parquet => rust/parquet}/src/arrow/mod.rs | 0
.../parquet}/src/arrow/record_reader.rs | 0
{parquet => rust/parquet}/src/arrow/schema.rs | 0
{parquet => rust/parquet}/src/basic.rs | 0
{parquet => rust/parquet}/src/bin/parquet-read.rs | 0
.../parquet}/src/bin/parquet-rowcount.rs | 0
.../parquet}/src/bin/parquet-schema.rs | 0
{parquet => rust/parquet}/src/column/mod.rs | 0
{parquet => rust/parquet}/src/column/page.rs | 0
{parquet => rust/parquet}/src/column/reader.rs | 0
{parquet => rust/parquet}/src/column/writer.rs | 0
{parquet => rust/parquet}/src/compression.rs | 0
{parquet => rust/parquet}/src/data_type.rs | 0
.../parquet}/src/encodings/decoding.rs | 0
.../parquet}/src/encodings/encoding.rs | 0
{parquet => rust/parquet}/src/encodings/levels.rs | 0
{parquet => rust/parquet}/src/encodings/mod.rs | 0
{parquet => rust/parquet}/src/encodings/rle.rs | 0
{parquet => rust/parquet}/src/errors.rs | 0
{parquet => rust/parquet}/src/file/footer.rs | 0
{parquet => rust/parquet}/src/file/metadata.rs | 0
{parquet => rust/parquet}/src/file/mod.rs | 0
{parquet => rust/parquet}/src/file/properties.rs | 0
{parquet => rust/parquet}/src/file/reader.rs | 0
.../parquet}/src/file/serialized_reader.rs | 0
{parquet => rust/parquet}/src/file/statistics.rs | 0
{parquet => rust/parquet}/src/file/writer.rs | 0
{parquet => rust/parquet}/src/lib.rs | 0
{parquet => rust/parquet}/src/record/api.rs | 0
{parquet => rust/parquet}/src/record/mod.rs | 0
{parquet => rust/parquet}/src/record/reader.rs | 0
.../parquet}/src/record/record_writer.rs | 0
{parquet => rust/parquet}/src/record/triplet.rs | 0
{parquet => rust/parquet}/src/schema/mod.rs | 0
{parquet => rust/parquet}/src/schema/parser.rs | 0
{parquet => rust/parquet}/src/schema/printer.rs | 0
{parquet => rust/parquet}/src/schema/types.rs | 0
{parquet => rust/parquet}/src/schema/visitor.rs | 0
{parquet => rust/parquet}/src/util/bit_packing.rs | 0
{parquet => rust/parquet}/src/util/bit_util.rs | 0
{parquet => rust/parquet}/src/util/cursor.rs | 0
{parquet => rust/parquet}/src/util/hash_util.rs | 0
{parquet => rust/parquet}/src/util/io.rs | 0
{parquet => rust/parquet}/src/util/memory.rs | 0
{parquet => rust/parquet}/src/util/mod.rs | 0
.../parquet}/src/util/test_common/file_util.rs | 0
.../parquet}/src/util/test_common/mod.rs | 0
.../parquet}/src/util/test_common/page_util.rs | 0
.../parquet}/src/util/test_common/rand_gen.rs | 0
{parquet => rust/parquet}/tests/custom_writer.rs | 0
{parquet_derive => rust/parquet_derive}/Cargo.toml | 0
{parquet_derive => rust/parquet_derive}/README.md | 0
{parquet_derive => rust/parquet_derive}/src/lib.rs | 0
.../parquet_derive}/src/parquet_field.rs | 0
.../parquet_derive_test}/Cargo.toml | 0
.../parquet_derive_test}/src/lib.rs | 0
pre-commit.sh => rust/pre-commit.sh | 0
rustfmt.toml => rust/rustfmt.toml | 0
579 files changed, 79391 insertions(+), 730 deletions(-)
copy arrow-pyarrow-integration-testing/pyproject.toml => .clang-format (91%)
create mode 100644 .clang-tidy
copy arrow-pyarrow-integration-testing/pyproject.toml => .clang-tidy-ignore (92%)
create mode 100644 .dir-locals.el
create mode 100644 .env
create mode 100644 .github/workflows/cpp.yml
create mode 100644 .github/workflows/cpp_cron.yml
create mode 100644 .github/workflows/csharp.yml
create mode 100644 .github/workflows/go.yml
create mode 100644 .github/workflows/java.yml
create mode 100644 .github/workflows/java_jni.yml
create mode 100644 .github/workflows/js.yml
create mode 100644 .github/workflows/julia.yml
create mode 100644 .github/workflows/python.yml
create mode 100644 .github/workflows/python_cron.yml
create mode 100644 .github/workflows/r.yml
create mode 100644 .github/workflows/ruby.yml
copy rustfmt.toml => .hadolint.yaml (79%)
copy arrow-pyarrow-integration-testing/pyproject.toml => .readthedocs.yml (92%)
create mode 100644 .travis.yml
create mode 100644 appveyor.yml
create mode 100644 cmake-format.py
delete mode 160000 parquet-testing
create mode 100755 run-cmake-format.py
copy .gitignore => rust/.gitignore (100%)
rename Cargo.toml => rust/Cargo.toml (90%)
copy README.md => rust/README.md (100%)
copy {arrow-flight => rust/arrow-flight}/Cargo.toml (100%)
rename {arrow-flight => rust/arrow-flight}/README.md (100%)
rename {arrow-flight => rust/arrow-flight}/build.rs (91%)
copy {arrow-flight => rust/arrow-flight}/examples/server.rs (100%)
rename {arrow-flight => rust/arrow-flight}/src/arrow.flight.protocol.rs (100%)
copy {arrow-flight => rust/arrow-flight}/src/lib.rs (100%)
rename {arrow-flight => rust/arrow-flight}/src/utils.rs (100%)
copy {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/.cargo/config (100%)
rename {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/.gitignore (100%)
rename {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/Cargo.toml (100%)
rename {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/README.md (100%)
copy {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/pyproject.toml (100%)
rename {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/src/lib.rs (100%)
rename {arrow-pyarrow-integration-testing => rust/arrow-pyarrow-integration-testing}/tests/test_sql.py (100%)
rename {arrow => rust/arrow}/Cargo.toml (100%)
rename {arrow => rust/arrow}/README.md (100%)
rename {arrow => rust/arrow}/benches/aggregate_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/arithmetic_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/array_from_vec.rs (100%)
rename {arrow => rust/arrow}/benches/array_slice.rs (100%)
rename {arrow => rust/arrow}/benches/bit_length_kernel.rs (100%)
rename {arrow => rust/arrow}/benches/boolean_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/buffer_bit_ops.rs (100%)
rename {arrow => rust/arrow}/benches/buffer_create.rs (100%)
rename {arrow => rust/arrow}/benches/builder.rs (100%)
rename {arrow => rust/arrow}/benches/cast_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/comparison_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/concatenate_kernel.rs (100%)
rename {arrow => rust/arrow}/benches/csv_writer.rs (100%)
rename {arrow => rust/arrow}/benches/equal.rs (100%)
rename {arrow => rust/arrow}/benches/filter_kernels.rs (100%)
rename {arrow => rust/arrow}/benches/json_reader.rs (100%)
rename {arrow => rust/arrow}/benches/length_kernel.rs (100%)
rename {arrow => rust/arrow}/benches/mutable_array.rs (100%)
rename {arrow => rust/arrow}/benches/sort_kernel.rs (100%)
rename {arrow => rust/arrow}/benches/take_kernels.rs (100%)
copy {arrow => rust/arrow}/build.rs (100%)
rename {arrow => rust/arrow}/examples/builders.rs (100%)
rename {arrow => rust/arrow}/examples/dynamic_types.rs (100%)
rename {arrow => rust/arrow}/examples/read_csv.rs (100%)
rename {arrow => rust/arrow}/examples/read_csv_infer_schema.rs (100%)
rename {arrow => rust/arrow}/examples/tensor_builder.rs (100%)
rename {arrow => rust/arrow}/format-0ed34c83.patch (100%)
rename {arrow => rust/arrow}/regen.sh (100%)
rename {arrow => rust/arrow}/src/alloc/alignment.rs (100%)
rename {arrow => rust/arrow}/src/alloc/mod.rs (100%)
rename {arrow => rust/arrow}/src/alloc/types.rs (100%)
rename {arrow => rust/arrow}/src/arch/avx512.rs (100%)
rename {arrow => rust/arrow}/src/arch/mod.rs (100%)
rename {arrow => rust/arrow}/src/array/array.rs (100%)
rename {arrow => rust/arrow}/src/array/array_binary.rs (100%)
rename {arrow => rust/arrow}/src/array/array_boolean.rs (100%)
rename {arrow => rust/arrow}/src/array/array_dictionary.rs (100%)
rename {arrow => rust/arrow}/src/array/array_list.rs (100%)
rename {arrow => rust/arrow}/src/array/array_primitive.rs (100%)
rename {arrow => rust/arrow}/src/array/array_string.rs (100%)
rename {arrow => rust/arrow}/src/array/array_struct.rs (100%)
rename {arrow => rust/arrow}/src/array/array_union.rs (100%)
rename {arrow => rust/arrow}/src/array/builder.rs (100%)
rename {arrow => rust/arrow}/src/array/cast.rs (100%)
rename {arrow => rust/arrow}/src/array/data.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/boolean.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/decimal.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/dictionary.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/fixed_binary.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/fixed_list.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/list.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/mod.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/null.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/primitive.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/structure.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/utils.rs (100%)
rename {arrow => rust/arrow}/src/array/equal/variable_size.rs (100%)
rename {arrow => rust/arrow}/src/array/equal_json.rs (100%)
rename {arrow => rust/arrow}/src/array/ffi.rs (100%)
rename {arrow => rust/arrow}/src/array/iterator.rs (100%)
rename {arrow => rust/arrow}/src/array/mod.rs (100%)
rename {arrow => rust/arrow}/src/array/null.rs (100%)
rename {arrow => rust/arrow}/src/array/ord.rs (100%)
rename {arrow => rust/arrow}/src/array/raw_pointer.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/boolean.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/fixed_binary.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/list.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/mod.rs (100%)
copy {arrow => rust/arrow}/src/array/transform/null.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/primitive.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/structure.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/utils.rs (100%)
rename {arrow => rust/arrow}/src/array/transform/variable_size.rs (100%)
rename {arrow => rust/arrow}/src/bitmap.rs (100%)
rename {arrow => rust/arrow}/src/buffer/immutable.rs (100%)
rename {arrow => rust/arrow}/src/buffer/mod.rs (100%)
rename {arrow => rust/arrow}/src/buffer/mutable.rs (100%)
rename {arrow => rust/arrow}/src/buffer/ops.rs (100%)
rename {arrow => rust/arrow}/src/bytes.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/aggregate.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/arithmetic.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/arity.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/boolean.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/cast.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/cast_utils.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/comparison.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/concat.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/filter.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/length.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/limit.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/mod.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/regexp.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/sort.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/substring.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/take.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/temporal.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/window.rs (100%)
rename {arrow => rust/arrow}/src/compute/kernels/zip.rs (100%)
rename {arrow => rust/arrow}/src/compute/mod.rs (100%)
rename {arrow => rust/arrow}/src/compute/util.rs (100%)
copy {arrow => rust/arrow}/src/csv/mod.rs (100%)
rename {arrow => rust/arrow}/src/csv/reader.rs (100%)
rename {arrow => rust/arrow}/src/csv/writer.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/datatype.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/field.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/mod.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/native.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/numeric.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/schema.rs (100%)
rename {arrow => rust/arrow}/src/datatypes/types.rs (100%)
rename {arrow => rust/arrow}/src/error.rs (100%)
rename {arrow => rust/arrow}/src/ffi.rs (100%)
rename {arrow => rust/arrow}/src/ipc/convert.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/File.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/Message.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/Schema.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/SparseTensor.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/Tensor.rs (100%)
rename {arrow => rust/arrow}/src/ipc/gen/mod.rs (100%)
rename {arrow => rust/arrow}/src/ipc/mod.rs (100%)
rename {arrow => rust/arrow}/src/ipc/reader.rs (100%)
rename {arrow => rust/arrow}/src/ipc/writer.rs (100%)
rename {arrow => rust/arrow}/src/json/mod.rs (100%)
rename {arrow => rust/arrow}/src/json/reader.rs (100%)
rename {arrow => rust/arrow}/src/json/writer.rs (100%)
rename {arrow => rust/arrow}/src/lib.rs (100%)
rename {arrow => rust/arrow}/src/record_batch.rs (100%)
rename {arrow => rust/arrow}/src/temporal_conversions.rs (100%)
rename {arrow => rust/arrow}/src/tensor.rs (100%)
rename {arrow => rust/arrow}/src/util/bench_util.rs (100%)
rename {arrow => rust/arrow}/src/util/bit_chunk_iterator.rs (100%)
rename {arrow => rust/arrow}/src/util/bit_util.rs (100%)
rename {arrow => rust/arrow}/src/util/data_gen.rs (100%)
rename {arrow => rust/arrow}/src/util/display.rs (100%)
rename {arrow => rust/arrow}/src/util/integration_util.rs (100%)
rename {arrow => rust/arrow}/src/util/mod.rs (100%)
rename {arrow => rust/arrow}/src/util/pretty.rs (100%)
rename {arrow => rust/arrow}/src/util/serialization.rs (100%)
rename {arrow => rust/arrow}/src/util/string_writer.rs (100%)
rename {arrow => rust/arrow}/src/util/test_util.rs (98%)
rename {arrow => rust/arrow}/src/util/trusted_len.rs (100%)
rename {arrow => rust/arrow}/src/zz_memory_check.rs (100%)
rename {arrow => rust/arrow}/test/data/arrays.json (100%)
rename {arrow => rust/arrow}/test/data/basic.json (100%)
rename {arrow => rust/arrow}/test/data/basic_nulls.json (100%)
rename {arrow => rust/arrow}/test/data/integration.json (100%)
rename {arrow => rust/arrow}/test/data/list_string_dict_nested.json (100%)
rename {arrow => rust/arrow}/test/data/list_string_dict_nested_nulls.json (100%)
rename {arrow => rust/arrow}/test/data/mixed_arrays.json (100%)
rename {arrow => rust/arrow}/test/data/mixed_arrays.json.gz (100%)
rename {arrow => rust/arrow}/test/data/nested_structs.json (100%)
rename {arrow => rust/arrow}/test/data/null_test.csv (100%)
rename {arrow => rust/arrow}/test/data/uk_cities.csv (100%)
rename {arrow => rust/arrow}/test/data/uk_cities_with_headers.csv (100%)
rename {arrow => rust/arrow}/test/data/various_types.csv (100%)
rename {arrow => rust/arrow}/test/data/various_types_invalid.csv (100%)
copy arrow-pyarrow-integration-testing/pyproject.toml => rust/ballista/.dockerignore (92%)
create mode 100644 rust/ballista/README.md
copy rustfmt.toml => rust/ballista/dev/build-rust-base.sh (84%)
mode change 100644 => 100755
copy rustfmt.toml => rust/ballista/dev/build-rust.sh (84%)
mode change 100644 => 100755
copy rustfmt.toml => rust/ballista/dev/integration-tests.sh (82%)
mode change 100644 => 100755
copy {integration-testing => rust/ballista/docker}/README.md (59%)
create mode 100644 rust/ballista/docker/rust-base.dockerfile
create mode 100644 rust/ballista/docker/rust.dockerfile
copy {integration-testing => rust/ballista/docs}/README.md (50%)
create mode 100644 rust/ballista/docs/architecture.md
copy integration-testing/README.md => rust/ballista/docs/dev-env-rust.md (59%)
create mode 100644 rust/ballista/docs/images/query-execution.png
copy integration-testing/README.md => rust/ballista/docs/integration-testing.md (59%)
create mode 100644 rust/ballista/docs/release-process.md
create mode 100644 rust/ballista/docs/rust-docker.md
create mode 100644 rust/ballista/docs/user-guide/.gitignore
copy {integration-testing => rust/ballista/docs/user-guide}/README.md (59%)
copy rustfmt.toml => rust/ballista/docs/user-guide/book.toml (87%)
copy integration-testing/README.md => rust/ballista/docs/user-guide/src/SUMMARY.md (59%)
copy integration-testing/README.md => rust/ballista/docs/user-guide/src/client-rust.md (59%)
copy integration-testing/README.md => rust/ballista/docs/user-guide/src/clients.md (59%)
create mode 100644 rust/ballista/docs/user-guide/src/configuration.md
copy integration-testing/README.md => rust/ballista/docs/user-guide/src/deployment.md (59%)
create mode 100644 rust/ballista/docs/user-guide/src/docker-compose.md
copy integration-testing/README.md => rust/ballista/docs/user-guide/src/faq.md (57%)
create mode 100644 rust/ballista/docs/user-guide/src/img/ballista-architecture.png
create mode 100644 rust/ballista/docs/user-guide/src/introduction.md
create mode 100644 rust/ballista/docs/user-guide/src/kubernetes.md
create mode 100644 rust/ballista/docs/user-guide/src/standalone.md
copy arrow-pyarrow-integration-testing/pyproject.toml => rust/ballista/rust/.dockerignore (70%)
create mode 100644 rust/ballista/rust/.gitignore
copy rustfmt.toml => rust/ballista/rust/Cargo.toml (83%)
copy rustfmt.toml => rust/ballista/rust/benchmarks/tpch/.dockerignore (69%)
create mode 100644 rust/ballista/rust/benchmarks/tpch/.gitignore
copy {parquet_derive_test => rust/ballista/rust/benchmarks/tpch}/Cargo.toml (75%)
create mode 100644 rust/ballista/rust/benchmarks/tpch/README.md
create mode 100644 rust/ballista/rust/benchmarks/tpch/docker-compose.yaml
copy arrow-pyarrow-integration-testing/pyproject.toml => rust/ballista/rust/benchmarks/tpch/entrypoint.sh (92%)
mode change 100644 => 100755
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q1.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q10.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q11.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q12.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q13.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q14.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q16.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q17.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q18.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q19.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q2.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q20.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q21.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q22.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q3.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q4.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q5.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q6.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q7.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q8.sql
create mode 100644 rust/ballista/rust/benchmarks/tpch/queries/q9.sql
copy rustfmt.toml => rust/ballista/rust/benchmarks/tpch/run.sh (73%)
mode change 100644 => 100755
create mode 100644 rust/ballista/rust/benchmarks/tpch/src/main.rs
copy rustfmt.toml => rust/ballista/rust/benchmarks/tpch/tpch-gen.sh (64%)
mode change 100644 => 100755
copy rustfmt.toml => rust/ballista/rust/benchmarks/tpch/tpchgen.dockerfile (73%)
copy {parquet_derive_test => rust/ballista/rust/client}/Cargo.toml (77%)
copy {integration-testing => rust/ballista/rust/client}/README.md (59%)
create mode 100644 rust/ballista/rust/client/src/columnar_batch.rs
create mode 100644 rust/ballista/rust/client/src/context.rs
copy {arrow-flight => rust/ballista/rust/client}/src/lib.rs (93%)
copy arrow-flight/src/lib.rs => rust/ballista/rust/client/src/prelude.rs (83%)
rename {arrow-flight => rust/ballista/rust/core}/Cargo.toml (65%)
copy {integration-testing => rust/ballista/rust/core}/README.md (59%)
copy {arrow => rust/ballista/rust/core}/build.rs (68%)
create mode 100644 rust/ballista/rust/core/proto/ballista.proto
create mode 100644 rust/ballista/rust/core/src/client.rs
create mode 100644 rust/ballista/rust/core/src/datasource.rs
create mode 100644 rust/ballista/rust/core/src/error.rs
copy {arrow/src/csv => rust/ballista/rust/core/src/execution_plans}/mod.rs (70%)
create mode 100644 rust/ballista/rust/core/src/execution_plans/query_stage.rs
create mode 100644 rust/ballista/rust/core/src/execution_plans/shuffle_reader.rs
create mode 100644 rust/ballista/rust/core/src/execution_plans/unresolved_shuffle.rs
copy {arrow-flight => rust/ballista/rust/core}/src/lib.rs (71%)
create mode 100644 rust/ballista/rust/core/src/memory_stream.rs
create mode 100644 rust/ballista/rust/core/src/serde/logical_plan/from_proto.rs
create mode 100644 rust/ballista/rust/core/src/serde/logical_plan/mod.rs
create mode 100644 rust/ballista/rust/core/src/serde/logical_plan/to_proto.rs
create mode 100644 rust/ballista/rust/core/src/serde/mod.rs
create mode 100644 rust/ballista/rust/core/src/serde/physical_plan/from_proto.rs
create mode 100644 rust/ballista/rust/core/src/serde/physical_plan/mod.rs
create mode 100644 rust/ballista/rust/core/src/serde/physical_plan/to_proto.rs
create mode 100644 rust/ballista/rust/core/src/serde/scheduler/from_proto.rs
create mode 100644 rust/ballista/rust/core/src/serde/scheduler/mod.rs
create mode 100644 rust/ballista/rust/core/src/serde/scheduler/to_proto.rs
create mode 100644 rust/ballista/rust/core/src/utils.rs
copy {integration-testing => rust/ballista/rust/executor}/Cargo.toml (58%)
copy {integration-testing => rust/ballista/rust/executor}/README.md (59%)
copy {arrow => rust/ballista/rust/executor}/build.rs (75%)
rename arrow-pyarrow-integration-testing/.cargo/config => rust/ballista/rust/executor/examples/example_executor_config.toml (73%)
create mode 100644 rust/ballista/rust/executor/executor_config_spec.toml
create mode 100644 rust/ballista/rust/executor/src/collect.rs
create mode 100644 rust/ballista/rust/executor/src/execution_loop.rs
create mode 100644 rust/ballista/rust/executor/src/flight_service.rs
copy integration-testing/src/bin/arrow-stream-to-file.rs => rust/ballista/rust/executor/src/lib.rs (51%)
create mode 100644 rust/ballista/rust/executor/src/main.rs
copy {integration-testing => rust/ballista/rust/scheduler}/Cargo.toml (52%)
create mode 100644 rust/ballista/rust/scheduler/README.md
rename {arrow => rust/ballista/rust/scheduler}/build.rs (75%)
create mode 100644 rust/ballista/rust/scheduler/scheduler_config_spec.toml
create mode 100644 rust/ballista/rust/scheduler/src/api/handlers.rs
create mode 100644 rust/ballista/rust/scheduler/src/api/mod.rs
create mode 100644 rust/ballista/rust/scheduler/src/lib.rs
create mode 100644 rust/ballista/rust/scheduler/src/main.rs
create mode 100644 rust/ballista/rust/scheduler/src/planner.rs
create mode 100644 rust/ballista/rust/scheduler/src/state/etcd.rs
create mode 100644 rust/ballista/rust/scheduler/src/state/mod.rs
create mode 100644 rust/ballista/rust/scheduler/src/state/standalone.rs
create mode 100644 rust/ballista/rust/scheduler/src/test_utils.rs
create mode 100644 rust/ballista/rust/scheduler/testdata/customer/customer.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/lineitem/partition0.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/lineitem/partition1.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/nation/nation.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/orders/orders.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/part/part.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/partsupp/partsupp.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/region/region.tbl
create mode 100644 rust/ballista/rust/scheduler/testdata/supplier/supplier.tbl
create mode 100644 rust/ballista/ui/scheduler/.gitignore
copy {integration-testing => rust/ballista/ui/scheduler}/README.md (52%)
copy arrow-flight/src/lib.rs => rust/ballista/ui/scheduler/index.d.ts (93%)
create mode 100644 rust/ballista/ui/scheduler/package.json
create mode 100644 rust/ballista/ui/scheduler/public/favicon.ico
create mode 100644 rust/ballista/ui/scheduler/public/index.html
create mode 100644 rust/ballista/ui/scheduler/public/logo192.png
create mode 100644 rust/ballista/ui/scheduler/public/logo512.png
create mode 100644 rust/ballista/ui/scheduler/public/manifest.json
rename arrow-pyarrow-integration-testing/pyproject.toml => rust/ballista/ui/scheduler/public/robots.txt (92%)
create mode 100644 rust/ballista/ui/scheduler/react-table-config.d.ts
copy integration-testing/README.md => rust/ballista/ui/scheduler/src/App.css (58%)
copy arrow-flight/src/lib.rs => rust/ballista/ui/scheduler/src/App.test.tsx (74%)
create mode 100644 rust/ballista/ui/scheduler/src/App.tsx
create mode 100644 rust/ballista/ui/scheduler/src/components/DataTable.tsx
copy parquet/src/record/mod.rs => rust/ballista/ui/scheduler/src/components/Empty.tsx (68%)
rename arrow/src/csv/mod.rs => rust/ballista/ui/scheduler/src/components/Footer.tsx (68%)
create mode 100644 rust/ballista/ui/scheduler/src/components/Header.tsx
create mode 100644 rust/ballista/ui/scheduler/src/components/NodesList.tsx
create mode 100644 rust/ballista/ui/scheduler/src/components/QueriesList.tsx
create mode 100644 rust/ballista/ui/scheduler/src/components/Summary.tsx
create mode 100644 rust/ballista/ui/scheduler/src/components/logo.svg
copy integration-testing/README.md => rust/ballista/ui/scheduler/src/index.css (59%)
copy integration-testing/src/bin/arrow-stream-to-file.rs => rust/ballista/ui/scheduler/src/index.tsx (57%)
copy arrow-flight/src/lib.rs => rust/ballista/ui/scheduler/src/react-app-env.d.ts (93%)
copy parquet/src/record/mod.rs => rust/ballista/ui/scheduler/src/reportWebVitals.ts (65%)
copy integration-testing/src/flight_client_scenarios.rs => rust/ballista/ui/scheduler/src/setupTests.ts (76%)
create mode 100644 rust/ballista/ui/scheduler/tsconfig.json
create mode 100644 rust/ballista/ui/scheduler/yarn.lock
copy {integration-testing => rust/benchmarks}/Cargo.toml (67%)
create mode 100644 rust/benchmarks/README.md
create mode 100644 rust/benchmarks/src/bin/nyctaxi.rs
create mode 100644 rust/benchmarks/src/bin/tpch.rs
copy {integration-testing => rust/datafusion-examples}/Cargo.toml (74%)
copy {integration-testing => rust/datafusion-examples/examples}/README.md (59%)
create mode 100644 rust/datafusion-examples/examples/csv_sql.rs
create mode 100644 rust/datafusion-examples/examples/dataframe.rs
create mode 100644 rust/datafusion-examples/examples/dataframe_in_memory.rs
create mode 100644 rust/datafusion-examples/examples/flight_client.rs
rename arrow-flight/examples/server.rs => rust/datafusion-examples/examples/flight_server.rs (53%)
create mode 100644 rust/datafusion-examples/examples/parquet_sql.rs
create mode 100644 rust/datafusion-examples/examples/simple_udaf.rs
create mode 100644 rust/datafusion-examples/examples/simple_udf.rs
create mode 100644 rust/datafusion/Cargo.toml
create mode 100644 rust/datafusion/DEVELOPERS.md
copy rustfmt.toml => rust/datafusion/Dockerfile (79%)
create mode 100644 rust/datafusion/README.md
create mode 100644 rust/datafusion/benches/aggregate_query_sql.rs
create mode 100644 rust/datafusion/benches/filter_query_sql.rs
create mode 100644 rust/datafusion/benches/math_query_sql.rs
rename arrow/src/array/transform/null.rs => rust/datafusion/benches/scalar.rs (66%)
create mode 100644 rust/datafusion/benches/sort_limit_query_sql.rs
create mode 100644 rust/datafusion/docs/cli.md
create mode 100644 rust/datafusion/docs/images/DataFusion-Logo-Dark.png
create mode 100644 rust/datafusion/docs/images/DataFusion-Logo-Dark.svg
create mode 100644 rust/datafusion/docs/images/DataFusion-Logo-Light.png
create mode 100644 rust/datafusion/docs/images/DataFusion-Logo-Light.svg
copy arrow-flight/src/lib.rs => rust/datafusion/src/bin/main.rs (82%)
create mode 100644 rust/datafusion/src/bin/repl.rs
create mode 100644 rust/datafusion/src/catalog/catalog.rs
create mode 100644 rust/datafusion/src/catalog/information_schema.rs
create mode 100644 rust/datafusion/src/catalog/mod.rs
create mode 100644 rust/datafusion/src/catalog/schema.rs
create mode 100644 rust/datafusion/src/dataframe.rs
create mode 100644 rust/datafusion/src/datasource/csv.rs
create mode 100644 rust/datafusion/src/datasource/datasource.rs
create mode 100644 rust/datafusion/src/datasource/empty.rs
create mode 100644 rust/datafusion/src/datasource/memory.rs
copy {parquet/src/util => rust/datafusion/src/datasource}/mod.rs (79%)
create mode 100644 rust/datafusion/src/datasource/parquet.rs
create mode 100644 rust/datafusion/src/error.rs
create mode 100644 rust/datafusion/src/execution/context.rs
create mode 100644 rust/datafusion/src/execution/dataframe_impl.rs
copy arrow-flight/src/lib.rs => rust/datafusion/src/execution/mod.rs (91%)
create mode 100644 rust/datafusion/src/lib.rs
create mode 100644 rust/datafusion/src/logical_plan/builder.rs
create mode 100644 rust/datafusion/src/logical_plan/dfschema.rs
create mode 100644 rust/datafusion/src/logical_plan/display.rs
create mode 100644 rust/datafusion/src/logical_plan/expr.rs
create mode 100644 rust/datafusion/src/logical_plan/extension.rs
create mode 100644 rust/datafusion/src/logical_plan/mod.rs
create mode 100644 rust/datafusion/src/logical_plan/operators.rs
create mode 100644 rust/datafusion/src/logical_plan/plan.rs
copy integration-testing/src/bin/arrow-stream-to-file.rs => rust/datafusion/src/logical_plan/registry.rs (58%)
create mode 100644 rust/datafusion/src/optimizer/constant_folding.rs
create mode 100644 rust/datafusion/src/optimizer/filter_push_down.rs
create mode 100644 rust/datafusion/src/optimizer/hash_build_probe_order.rs
create mode 100644 rust/datafusion/src/optimizer/limit_push_down.rs
rename arrow-flight/src/lib.rs => rust/datafusion/src/optimizer/mod.rs (70%)
copy integration-testing/src/bin/arrow-stream-to-file.rs => rust/datafusion/src/optimizer/optimizer.rs (63%)
create mode 100644 rust/datafusion/src/optimizer/projection_push_down.rs
create mode 100644 rust/datafusion/src/optimizer/utils.rs
create mode 100644 rust/datafusion/src/physical_optimizer/coalesce_batches.rs
create mode 100644 rust/datafusion/src/physical_optimizer/merge_exec.rs
copy {parquet/src/util => rust/datafusion/src/physical_optimizer}/mod.rs (77%)
copy parquet/src/record/record_writer.rs => rust/datafusion/src/physical_optimizer/optimizer.rs (57%)
create mode 100644 rust/datafusion/src/physical_optimizer/repartition.rs
create mode 100644 rust/datafusion/src/physical_plan/aggregates.rs
create mode 100644 rust/datafusion/src/physical_plan/array_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/coalesce_batches.rs
create mode 100644 rust/datafusion/src/physical_plan/common.rs
create mode 100644 rust/datafusion/src/physical_plan/crypto_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/csv.rs
create mode 100644 rust/datafusion/src/physical_plan/datetime_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/distinct_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/empty.rs
create mode 100644 rust/datafusion/src/physical_plan/explain.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/average.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/binary.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/case.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/cast.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/coercion.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/column.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/count.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/in_list.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/is_not_null.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/is_null.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/literal.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/min_max.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/mod.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/negative.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/not.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/nullif.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/sum.rs
create mode 100644 rust/datafusion/src/physical_plan/expressions/try_cast.rs
create mode 100644 rust/datafusion/src/physical_plan/filter.rs
create mode 100644 rust/datafusion/src/physical_plan/functions.rs
create mode 100644 rust/datafusion/src/physical_plan/group_scalar.rs
create mode 100644 rust/datafusion/src/physical_plan/hash_aggregate.rs
create mode 100644 rust/datafusion/src/physical_plan/hash_join.rs
create mode 100644 rust/datafusion/src/physical_plan/hash_utils.rs
create mode 100644 rust/datafusion/src/physical_plan/limit.rs
create mode 100644 rust/datafusion/src/physical_plan/math_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/memory.rs
create mode 100644 rust/datafusion/src/physical_plan/merge.rs
create mode 100644 rust/datafusion/src/physical_plan/mod.rs
create mode 100644 rust/datafusion/src/physical_plan/parquet.rs
create mode 100644 rust/datafusion/src/physical_plan/planner.rs
create mode 100644 rust/datafusion/src/physical_plan/projection.rs
create mode 100644 rust/datafusion/src/physical_plan/regex_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/repartition.rs
create mode 100644 rust/datafusion/src/physical_plan/sort.rs
create mode 100644 rust/datafusion/src/physical_plan/string_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/type_coercion.rs
create mode 100644 rust/datafusion/src/physical_plan/udaf.rs
create mode 100644 rust/datafusion/src/physical_plan/udf.rs
create mode 100644 rust/datafusion/src/physical_plan/unicode_expressions.rs
create mode 100644 rust/datafusion/src/physical_plan/union.rs
create mode 100644 rust/datafusion/src/prelude.rs
create mode 100644 rust/datafusion/src/scalar.rs
copy {parquet/src/util => rust/datafusion/src/sql}/mod.rs (78%)
create mode 100644 rust/datafusion/src/sql/parser.rs
create mode 100644 rust/datafusion/src/sql/planner.rs
create mode 100644 rust/datafusion/src/sql/utils.rs
create mode 100644 rust/datafusion/src/test/exec.rs
create mode 100644 rust/datafusion/src/test/mod.rs
create mode 100644 rust/datafusion/src/test/user_defined.rs
create mode 100644 rust/datafusion/src/test/variable.rs
copy integration-testing/src/bin/arrow-stream-to-file.rs => rust/datafusion/src/variable/mod.rs (64%)
create mode 100644 rust/datafusion/tests/aggregate_simple.csv
create mode 100644 rust/datafusion/tests/custom_sources.rs
create mode 100644 rust/datafusion/tests/customer.csv
create mode 100644 rust/datafusion/tests/dataframe.rs
create mode 100644 rust/datafusion/tests/example.csv
create mode 100644 rust/datafusion/tests/provider_filter_pushdown.rs
create mode 100644 rust/datafusion/tests/sql.rs
create mode 100644 rust/datafusion/tests/user_defined_plan.rs
rename {integration-testing => rust/integration-testing}/Cargo.toml (100%)
rename {integration-testing => rust/integration-testing}/README.md (100%)
rename {integration-testing => rust/integration-testing}/src/bin/arrow-file-to-stream.rs (100%)
rename {integration-testing => rust/integration-testing}/src/bin/arrow-json-integration-test.rs (100%)
rename {integration-testing => rust/integration-testing}/src/bin/arrow-stream-to-file.rs (100%)
rename {integration-testing => rust/integration-testing}/src/bin/flight-test-integration-client.rs (100%)
rename {integration-testing => rust/integration-testing}/src/bin/flight-test-integration-server.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_client_scenarios.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_client_scenarios/auth_basic_proto.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_client_scenarios/integration_test.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_client_scenarios/middleware.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_server_scenarios.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_server_scenarios/auth_basic_proto.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_server_scenarios/integration_test.rs (100%)
rename {integration-testing => rust/integration-testing}/src/flight_server_scenarios/middleware.rs (100%)
rename {integration-testing => rust/integration-testing}/src/lib.rs (100%)
rename {parquet => rust/parquet}/Cargo.toml (100%)
rename {parquet => rust/parquet}/README.md (100%)
rename {parquet => rust/parquet}/benches/arrow_writer.rs (100%)
rename {parquet => rust/parquet}/build.rs (100%)
rename {parquet => rust/parquet}/src/arrow/array_reader.rs (100%)
rename {parquet => rust/parquet}/src/arrow/arrow_reader.rs (100%)
rename {parquet => rust/parquet}/src/arrow/arrow_writer.rs (100%)
rename {parquet => rust/parquet}/src/arrow/converter.rs (100%)
rename {parquet => rust/parquet}/src/arrow/levels.rs (100%)
rename {parquet => rust/parquet}/src/arrow/mod.rs (100%)
rename {parquet => rust/parquet}/src/arrow/record_reader.rs (100%)
rename {parquet => rust/parquet}/src/arrow/schema.rs (100%)
rename {parquet => rust/parquet}/src/basic.rs (100%)
rename {parquet => rust/parquet}/src/bin/parquet-read.rs (100%)
rename {parquet => rust/parquet}/src/bin/parquet-rowcount.rs (100%)
rename {parquet => rust/parquet}/src/bin/parquet-schema.rs (100%)
rename {parquet => rust/parquet}/src/column/mod.rs (100%)
rename {parquet => rust/parquet}/src/column/page.rs (100%)
rename {parquet => rust/parquet}/src/column/reader.rs (100%)
rename {parquet => rust/parquet}/src/column/writer.rs (100%)
rename {parquet => rust/parquet}/src/compression.rs (100%)
rename {parquet => rust/parquet}/src/data_type.rs (100%)
rename {parquet => rust/parquet}/src/encodings/decoding.rs (100%)
rename {parquet => rust/parquet}/src/encodings/encoding.rs (100%)
rename {parquet => rust/parquet}/src/encodings/levels.rs (100%)
rename {parquet => rust/parquet}/src/encodings/mod.rs (100%)
rename {parquet => rust/parquet}/src/encodings/rle.rs (100%)
rename {parquet => rust/parquet}/src/errors.rs (100%)
rename {parquet => rust/parquet}/src/file/footer.rs (100%)
rename {parquet => rust/parquet}/src/file/metadata.rs (100%)
rename {parquet => rust/parquet}/src/file/mod.rs (100%)
rename {parquet => rust/parquet}/src/file/properties.rs (100%)
rename {parquet => rust/parquet}/src/file/reader.rs (100%)
rename {parquet => rust/parquet}/src/file/serialized_reader.rs (100%)
rename {parquet => rust/parquet}/src/file/statistics.rs (100%)
rename {parquet => rust/parquet}/src/file/writer.rs (100%)
rename {parquet => rust/parquet}/src/lib.rs (100%)
rename {parquet => rust/parquet}/src/record/api.rs (100%)
rename {parquet => rust/parquet}/src/record/mod.rs (100%)
rename {parquet => rust/parquet}/src/record/reader.rs (100%)
rename {parquet => rust/parquet}/src/record/record_writer.rs (100%)
rename {parquet => rust/parquet}/src/record/triplet.rs (100%)
rename {parquet => rust/parquet}/src/schema/mod.rs (100%)
rename {parquet => rust/parquet}/src/schema/parser.rs (100%)
rename {parquet => rust/parquet}/src/schema/printer.rs (100%)
rename {parquet => rust/parquet}/src/schema/types.rs (100%)
rename {parquet => rust/parquet}/src/schema/visitor.rs (100%)
rename {parquet => rust/parquet}/src/util/bit_packing.rs (100%)
rename {parquet => rust/parquet}/src/util/bit_util.rs (100%)
rename {parquet => rust/parquet}/src/util/cursor.rs (100%)
rename {parquet => rust/parquet}/src/util/hash_util.rs (100%)
rename {parquet => rust/parquet}/src/util/io.rs (100%)
rename {parquet => rust/parquet}/src/util/memory.rs (100%)
rename {parquet => rust/parquet}/src/util/mod.rs (100%)
rename {parquet => rust/parquet}/src/util/test_common/file_util.rs (100%)
rename {parquet => rust/parquet}/src/util/test_common/mod.rs (100%)
rename {parquet => rust/parquet}/src/util/test_common/page_util.rs (100%)
rename {parquet => rust/parquet}/src/util/test_common/rand_gen.rs (100%)
rename {parquet => rust/parquet}/tests/custom_writer.rs (100%)
rename {parquet_derive => rust/parquet_derive}/Cargo.toml (100%)
rename {parquet_derive => rust/parquet_derive}/README.md (100%)
rename {parquet_derive => rust/parquet_derive}/src/lib.rs (100%)
rename {parquet_derive => rust/parquet_derive}/src/parquet_field.rs (100%)
rename {parquet_derive_test => rust/parquet_derive_test}/Cargo.toml (100%)
rename {parquet_derive_test => rust/parquet_derive_test}/src/lib.rs (100%)
rename pre-commit.sh => rust/pre-commit.sh (100%)
rename rustfmt.toml => rust/rustfmt.toml (100%)