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