feat(sink): support bigquery sink upsert

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.23"
 http = "0.2"
 hyper = { version = "0.14", features = [

src/connector/src/lib.rs

@@ -33,6 +33,7 @@
 #![feature(try_blocks)]
 #![feature(error_generic_member_access)]
 #![feature(register_tool)]
+#![feature(assert_matches)]
 #![register_tool(rw)]
 #![recursion_limit = "256"]