Skip to content
This repository has been archived by the owner on Jun 6, 2024. It is now read-only.

push based Vayu Execution Engine with multiple pipelines support #4

Merged
merged 28 commits into from
Mar 27, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
a331889
main function for datafusion - run custom execution engine using data…
yashkothari42 Feb 23, 2024
1b206f0
scan and filter working
yashkothari42 Mar 5, 2024
31693cd
pipeline structs
yashkothari42 Mar 5, 2024
5b79c8a
pipeline with scan and filter operators
yashkothari42 Mar 6, 2024
533c7fb
unused imports removed
yashkothari42 Mar 6, 2024
5aaaf75
added vayu crate
yashkothari42 Mar 6, 2024
67af6b2
partial projection
yashkothari42 Mar 7, 2024
154505c
using dyn ExecutionPlan directly instead of converting to proto:Scan …
yashkothari42 Mar 9, 2024
fe31165
trying to implement operators without modifiying datafusion code.
yashkothari42 Mar 9, 2024
e4773c0
scan and filter working
yashkothari42 Mar 9, 2024
09b27e5
removed arrow/datafusion
yashkothari42 Mar 9, 2024
340a6e9
updated with yashkothari42/arrow-datafusion
yashkothari42 Mar 9, 2024
f02defe
updated datafusion
yashkothari42 Mar 9, 2024
af0d7f4
removed unused imports
yashkothari42 Mar 9, 2024
c0b2766
projection working
yashkothari42 Mar 9, 2024
39d85af
change operator batch size
yashkothari42 Mar 9, 2024
0fb44d0
revert join query
yashkothari42 Mar 13, 2024
0ec5347
add lighting
yashkothari42 Mar 20, 2024
2443f33
add SchedulerPipeline
yashkothari42 Mar 20, 2024
28c43c3
update vayu readme
yashkothari42 Mar 20, 2024
098854e
add SchedulerSink and SchedulerSinkType
yashkothari42 Mar 20, 2024
e1d82d3
added store and integrated with pipeline
yashkothari42 Mar 20, 2024
eb1ce2b
missed some files
yashkothari42 Mar 20, 2024
e12b194
join working
yashkothari42 Mar 26, 2024
a049089
update arrow datafusion
yashkothari42 Mar 26, 2024
8c29e3a
simplied logic, removed useless stuff
yashkothari42 Mar 26, 2024
d16fc04
cleaned and comments
yashkothari42 Mar 27, 2024
10d01f9
executor sink
yashkothari42 Mar 27, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Binary file added .DS_Store
Binary file not shown.
3 changes: 3 additions & 0 deletions .gitmodules
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
[submodule "arrow-datafusion"]
path = arrow-datafusion
url = [email protected]:yashkothari42/arrow-datafusion.git
5 changes: 5 additions & 0 deletions .vscode/settings.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
{
"rust-analyzer.linkedProjects": [
"./Cargo.toml"
]
}
10 changes: 6 additions & 4 deletions Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
[workspace]
members = ["datafusion-integration", "lighting", "vayu"]
exclude = ["arrow-datafusion"]

[package]
name = "ee2"
version = "0.1.0"
Expand All @@ -6,7 +10,5 @@ edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
substrait = "0.24.1"
prost = "0.12"
prost-types = "0.12"
protoc-rust = "2.28.0"
arrow = { version = "50.0.0"}
tokio = { version = "1.4.0", features = ["rt", "rt-multi-thread", "macros"] }
1 change: 1 addition & 0 deletions arrow-datafusion
Submodule arrow-datafusion added at 4fcb0b
Binary file added datafusion-integration/.DS_Store
Binary file not shown.
16 changes: 16 additions & 0 deletions datafusion-integration/Cargo.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
[package]
name = "datafusion_integration"
version = "0.1.0"
edition = "2021"

# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
arrow = { version = "50.0.0"}
tokio = { version = "1.4.0", features = ["rt", "rt-multi-thread", "macros"] }
vayu = { path = "../vayu", version = "0.1.0"}
datafusion = { version = "36.0.0", path = "../arrow-datafusion/datafusion/core"}
datafusion-proto = { version = "36.0.0", path = "../arrow-datafusion/datafusion/proto"}
ahash = { version = "0.8", default-features = false, features = [
"runtime-rng",
] }
Loading
Loading