This is an automated email from the ASF dual-hosted git repository. liyuanjian pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/spark-connect-rust.git
commit 257df1cd6c31a968e2e7b18a4c149057f2f6d394 Merge: 84db605 379e775 Author: Li Yuanjian <liyuanj...@apache.org> AuthorDate: Wed Jul 23 13:34:02 2025 -0700 Merge pull request #1 from sjrusso8/source ### Initial Merge Notice This is the initial merge from the original project into the Apache repository. - **Apache Spark PMC Acceptance Vote:** [https://lists.apache.org/thread/mj3ggbsqhjr2lblffmyn1rq5zcfckcrn](https://lists.apache.org/thread/mj3ggbsqhjr2lblffmyn1rq5zcfckcrn) - **IP Clearance File:** [https://svn.apache.org/repos/asf/incubator/public/trunk/content/ip-clearance/spark-connect-rust.xml](https://svn.apache.org/repos/asf/incubator/public/trunk/content/ip-clearance/spark-connect-rust.xml) All four contributors have ICLAs on file: - **Steve Russo** – Filed 2025-06-25 - **Stephen Carman** – Filed 2025-06-25 - **Alexander Brassel** – Filed 2025-07-03 - **Irfan Ghat** – Filed 2025-07-04 .github/pull_request_template.md | 35 + .github/workflows/build.yml | 115 + .github/workflows/release.yml | 64 + .gitignore | 24 + .pre-commit-config.yaml | 35 + Cargo.lock | 3843 ++++++++++++++++++++ Cargo.toml | 62 + README.md | 967 ++++- crates/connect/Cargo.toml | 98 + crates/connect/build.rs | 38 + crates/connect/protobuf/spark-3.5/buf.yaml | 25 + .../protobuf/spark-3.5/spark/connect/base.proto | 816 +++++ .../protobuf/spark-3.5/spark/connect/catalog.proto | 243 ++ .../spark-3.5/spark/connect/commands.proto | 416 +++ .../protobuf/spark-3.5/spark/connect/common.proto | 48 + .../spark-3.5/spark/connect/expressions.proto | 382 ++ .../spark-3.5/spark/connect/relations.proto | 1003 +++++ .../protobuf/spark-3.5/spark/connect/types.proto | 195 + crates/connect/src/catalog.rs | 972 +++++ crates/connect/src/client/builder.rs | 273 ++ crates/connect/src/client/config.rs | 120 + crates/connect/src/client/middleware.rs | 108 + crates/connect/src/client/mod.rs | 639 ++++ crates/connect/src/column.rs | 513 +++ crates/connect/src/conf.rs | 149 + crates/connect/src/dataframe.rs | 2784 ++++++++++++++ crates/connect/src/errors.rs | 194 + crates/connect/src/expressions.rs | 268 ++ crates/connect/src/functions/mod.rs | 2549 +++++++++++++ crates/connect/src/group.rs | 238 ++ crates/connect/src/lib.rs | 153 + crates/connect/src/plan.rs | 872 +++++ crates/connect/src/readwriter.rs | 1312 +++++++ crates/connect/src/session.rs | 477 +++ crates/connect/src/storage.rs | 135 + crates/connect/src/streaming/mod.rs | 1028 ++++++ crates/connect/src/types.rs | 717 ++++ crates/connect/src/window.rs | 443 +++ datasets/dir1/dir2/file2.parquet | Bin 0 -> 520 bytes datasets/dir1/file1.parquet | Bin 0 -> 520 bytes datasets/dir1/file3.json | 1 + datasets/employees.json | 4 + datasets/full_user.avsc | 1 + datasets/kv1.txt | 500 +++ datasets/people.csv | 3 + datasets/people.json | 3 + datasets/people.txt | 3 + datasets/user.avsc | 8 + datasets/users.avro | Bin 0 -> 334 bytes datasets/users.orc | Bin 0 -> 547 bytes datasets/users.parquet | Bin 0 -> 615 bytes docker-compose.yml | 33 + examples/Cargo.toml | 56 + examples/README.md | 92 + examples/src/databricks.rs | 80 + examples/src/deltalake.rs | 121 + examples/src/reader.rs | 65 + examples/src/readstream.rs | 57 + examples/src/sql.rs | 57 + examples/src/writer.rs | 77 + pre-commit.sh | 86 + 61 files changed, 23599 insertions(+), 1 deletion(-) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org