From 9a581321e8f44d71f640d65614c7837e0dcf7bb6 Mon Sep 17 00:00:00 2001 From: "mkuthan-scala-steward[bot]" <141544182+mkuthan-scala-steward[bot]@users.noreply.github.com> Date: Tue, 6 Feb 2024 11:04:37 +0000 Subject: [PATCH] Dependency updates (#146) * Update scio-core to 0.14.0 * Update scio-google-cloud-platform to 0.14.0 * Update scio-test to 0.14.0 * Fix BigQueryServicesFactory after Scio / Beam update --------- Co-authored-by: mkuthan-scala-steward[bot] <141544182+mkuthan-scala-steward[bot]@users.noreply.github.com> Co-authored-by: Marcin Kuthan --- project/Dependencies.scala | 6 +++--- .../beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala | 3 +++ 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/project/Dependencies.scala b/project/Dependencies.scala index 6a7ce923..2a1df8f0 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -1,13 +1,13 @@ import sbt._ object Dependencies { - val scio = "com.spotify" %% "scio-core" % "0.13.6" + val scio = "com.spotify" %% "scio-core" % "0.14.0" - val scioGcp = "com.spotify" %% "scio-google-cloud-platform" % "0.13.6" excludeAll ( + val scioGcp = "com.spotify" %% "scio-google-cloud-platform" % "0.14.0" excludeAll ( ExclusionRule(organization = "org.apache.beam", name = "beam-runners-direct-java") ) - val scioTest = "com.spotify" %% "scio-test" % "0.13.6" excludeAll ( + val scioTest = "com.spotify" %% "scio-test" % "0.14.0" excludeAll ( ExclusionRule(organization = "org.apache.beam", name = "beam-runners-direct-java") ) diff --git a/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala b/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala index a53e6d84..9430e915 100644 --- a/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala +++ b/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala @@ -12,4 +12,7 @@ object BigQueryServicesFactory extends BigQueryServices { override def getStorageClient(options: BigQueryOptions): BigQueryServices.StorageClient = new BigQueryServicesImpl().getStorageClient(options) + + override def getWriteStreamService(options: BigQueryOptions): BigQueryServices.WriteStreamService = + new BigQueryServicesImpl().getWriteStreamService(options) }