support bigquery cdc

risingwavelabs · Mar 19, 2024 · af66328 · af66328
1 parent d7e4a39
commit af66328
Show file tree

Hide file tree

Showing 10 changed files with 496 additions and 164 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml
@@ -57,6 +57,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 = [
@@ -114,9 +117,6 @@ redis = { version = "0.24.0", features = [
 regex = "1.4"
 reqwest = { version = "0.11", features = ["json"] }
 risingwave_common = { workspace = true }
-google-cloud-bigquery = { version = "0.7.0", features = ["auth"] }
-google-cloud-gax = "0.17.0"
-google-cloud-googleapis = "0.12.0"
 risingwave_jni_core = { workspace = true }
 risingwave_pb = { workspace = true }
 risingwave_rpc_client = { workspace = true }

diff --git a/src/connector/src/lib.rs b/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"]