feat(sink): support bigquery sink upsert (#15780)

Co-authored-by: xxhZs <xxhZs@users.noreply.github.com>
risingwavelabs · Apr 26, 2024 · 2dcd0f6 · 2dcd0f6
1 parent a692ed0
commit 2dcd0f6
Show file tree

Hide file tree

Showing 7 changed files with 614 additions and 135 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml
@@ -58,6 +58,9 @@ futures = { version = "0.3", default-features = false, features = ["alloc"] }
 futures-async-stream = { workspace = true }
 gcp-bigquery-client = "0.18.0"
 glob = "0.3"
+google-cloud-bigquery = { version = "0.7.0", features = ["auth"] }
+google-cloud-gax = "0.17.0"
+google-cloud-googleapis = "0.12.0"
 google-cloud-pubsub = "0.24"
 http = "0.2"
 icelake = { workspace = true }

diff --git a/src/connector/src/lib.rs b/src/connector/src/lib.rs
@@ -34,6 +34,7 @@
 #![feature(error_generic_member_access)]
 #![feature(negative_impls)]
 #![feature(register_tool)]
+#![feature(assert_matches)]
 #![register_tool(rw)]
 #![recursion_limit = "256"]