Skip to content

Commit

Permalink
deps: update dependency com.google.cloud:google-cloud-pubsublite to v…
Browse files Browse the repository at this point in the history
…0.10.0 (#55)

* update

* update

* update

* update
  • Loading branch information
jiangmichaellll committed Feb 5, 2021
1 parent aaf4d4a commit 2bbd9df
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 26 deletions.
4 changes: 2 additions & 2 deletions pom.xml
Expand Up @@ -8,7 +8,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.google.cloud</groupId>
<artifactId>pubsublite-spark-sql-streaming</artifactId>
<version>0.0.1-SNAPSHOT</version><!-- {x-version-update:pubsublite-spark-sql-streaming:current} -->
<version>0.1.0-SNAPSHOT</version><!-- {x-version-update:pubsublite-spark-sql-streaming:current} -->
<packaging>jar</packaging>
<name>Pub/Sub Lite Spark SQL Streaming</name>
<url>https://github.com/googleapis/java-pubsublite-spark</url>
Expand Down Expand Up @@ -43,7 +43,7 @@
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-pubsublite</artifactId>
<version>0.8.0</version>
<version>0.10.0</version>
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
Expand Down
8 changes: 0 additions & 8 deletions samples/snapshot/pom.xml
Expand Up @@ -23,15 +23,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<!-- {x-version-update-start:pubsublite-spark:current} -->
<dependencies>
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>pubsublite-spark-sql-streaming</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- {x-version-update-end} -->

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
Expand Down
11 changes: 0 additions & 11 deletions samples/snippets/pom.xml
Expand Up @@ -24,17 +24,6 @@
</properties>

<dependencies>
<!-- TODO: switch to libraries-bom after this artifact is included -->
<!-- [START pubsublite-spark_install_without_bom] -->
<!-- [START pubsublite-spark_java_dependencies] -->
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>pubsublite-spark-sql-streaming</artifactId>
<version>0.0.0</version>
</dependency>
<!-- [END pubsublite-spark_java_dependencies] -->
<!-- [END pubsublite-spark_install_without_bom] -->

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
Expand Down
Expand Up @@ -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;
Expand Down Expand Up @@ -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() {
Expand All @@ -136,7 +137,6 @@ PartitionSubscriberFactory getSubscriberFactory() {
return SubscriberBuilder.newBuilder()
.setSubscriptionPath(this.subscriptionPath())
.setPartition(partition)
.setContext(context)
.setServiceClient(serviceClient)
.setMessageConsumer(consumer)
.build();
Expand Down
2 changes: 1 addition & 1 deletion 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

0 comments on commit 2bbd9df

Please sign in to comment.