From 2bbd9df694529fa752ea62f98c89cac97a1766d1 Mon Sep 17 00:00:00 2001
From: jiangmichaellll <40044148+jiangmichaellll@users.noreply.github.com>
Date: Fri, 5 Feb 2021 16:06:06 -0500
Subject: [PATCH] deps: update dependency
com.google.cloud:google-cloud-pubsublite to v0.10.0 (#55)
* update
* update
* update
* update
---
pom.xml | 4 ++--
samples/snapshot/pom.xml | 8 --------
samples/snippets/pom.xml | 11 -----------
.../cloud/pubsublite/spark/PslDataSourceOptions.java | 8 ++++----
versions.txt | 2 +-
5 files changed, 7 insertions(+), 26 deletions(-)
diff --git a/pom.xml b/pom.xml
index c97c2b83..0ffa796e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -8,7 +8,7 @@
4.0.0
com.google.cloud
pubsublite-spark-sql-streaming
- 0.0.1-SNAPSHOT
+ 0.1.0-SNAPSHOT
jar
Pub/Sub Lite Spark SQL Streaming
https://github.com/googleapis/java-pubsublite-spark
@@ -43,7 +43,7 @@
com.google.cloud
google-cloud-pubsublite
- 0.8.0
+ 0.10.0
com.google.api.grpc
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index fc38a7d6..72fa7ce5 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -23,15 +23,7 @@
UTF-8
-
-
- com.google.cloud
- pubsublite-spark-sql-streaming
- 0.0.1-SNAPSHOT
-
-
-
junit
junit
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index ae1608c6..3a870822 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -24,17 +24,6 @@
-
-
-
-
- com.google.cloud
- pubsublite-spark-sql-streaming
- 0.0.0
-
-
-
-
junit
junit
diff --git a/src/main/java/com/google/cloud/pubsublite/spark/PslDataSourceOptions.java b/src/main/java/com/google/cloud/pubsublite/spark/PslDataSourceOptions.java
index 3a390eaf..ca02995d 100644
--- a/src/main/java/com/google/cloud/pubsublite/spark/PslDataSourceOptions.java
+++ b/src/main/java/com/google/cloud/pubsublite/spark/PslDataSourceOptions.java
@@ -27,7 +27,7 @@
import com.google.cloud.pubsublite.internal.CursorClientSettings;
import com.google.cloud.pubsublite.internal.TopicStatsClient;
import com.google.cloud.pubsublite.internal.TopicStatsClientSettings;
-import com.google.cloud.pubsublite.internal.wire.CommitterBuilder;
+import com.google.cloud.pubsublite.internal.wire.CommitterSettings;
import com.google.cloud.pubsublite.internal.wire.PubsubContext;
import com.google.cloud.pubsublite.internal.wire.RoutingMetadata;
import com.google.cloud.pubsublite.internal.wire.ServiceClients;
@@ -114,11 +114,12 @@ MultiPartitionCommitter newMultiPartitionCommitter(long topicPartitionCount) {
return new MultiPartitionCommitterImpl(
topicPartitionCount,
(partition) ->
- CommitterBuilder.newBuilder()
+ CommitterSettings.newBuilder()
.setSubscriptionPath(this.subscriptionPath())
.setPartition(partition)
.setServiceClient(newCursorServiceClient())
- .build());
+ .build()
+ .instantiate());
}
PartitionSubscriberFactory getSubscriberFactory() {
@@ -136,7 +137,6 @@ PartitionSubscriberFactory getSubscriberFactory() {
return SubscriberBuilder.newBuilder()
.setSubscriptionPath(this.subscriptionPath())
.setPartition(partition)
- .setContext(context)
.setServiceClient(serviceClient)
.setMessageConsumer(consumer)
.build();
diff --git a/versions.txt b/versions.txt
index 788083cc..f25538f2 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,4 +1,4 @@
# Format:
# module:released-version:current-version
-pubsublite-spark-sql-streaming:0.0.0:0.0.1-SNAPSHOT
+pubsublite-spark-sql-streaming:0.0.0:0.1.0-SNAPSHOT