Skip to content

Commit 96edda4

Browse files
authored
remove pubsublite from java sdk (#37448)
* remove pubsublite from java sdk * revert builde file change impacting pubsub * remove unused dependencies
1 parent 9fcb174 commit 96edda4

66 files changed

Lines changed: 1 addition & 4870 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

runners/google-cloud-dataflow-java/build.gradle

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,6 @@ dependencies {
102102
permitUnusedDeclared library.java.flogger_system_backend
103103
implementation library.java.google_api_client
104104
// Ensures SequencedMessage availability for Spotless
105-
implementation library.java.proto_google_cloud_pubsublite_v1
106-
permitUnusedDeclared library.java.proto_google_cloud_pubsublite_v1
107105
implementation library.java.google_api_services_dataflow
108106
implementation library.java.google_api_services_storage
109107
permitUnusedDeclared library.java.google_api_services_storage // BEAM-11761

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,6 @@
9696
import org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder;
9797
import org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink;
9898
import org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource;
99-
import org.apache.beam.sdk.io.gcp.pubsublite.internal.SubscribeTransform;
10099
import org.apache.beam.sdk.io.kafka.KafkaIO;
101100
import org.apache.beam.sdk.options.ExperimentalOptions;
102101
import org.apache.beam.sdk.options.PipelineOptions;
@@ -665,8 +664,6 @@ private List<PTransformOverride> getOverrides(boolean streaming) {
665664
// and only needed when KafkaIO is used in the pipeline.
666665
}
667666

668-
overridesBuilder.add(SubscribeTransform.V1_READ_OVERRIDE);
669-
670667
if (!hasExperiment(options, "enable_file_dynamic_sharding")) {
671668
overridesBuilder.add(
672669
PTransformOverride.of(

sdks/java/extensions/sql/build.gradle

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -103,12 +103,8 @@ dependencies {
103103
implementation library.java.proto_google_cloud_bigtable_v2
104104
implementation library.java.google_api_services_bigquery
105105
permitUnusedDeclared library.java.google_api_services_bigquery
106-
implementation library.java.proto_google_cloud_pubsublite_v1
107-
implementation library.java.google_cloud_pubsublite
108106
implementation project(":sdks:java:io:mongodb")
109107
implementation library.java.avro
110-
implementation library.java.protobuf_java
111-
implementation library.java.protobuf_java_util
112108
provided project(":sdks:java:io:parquet")
113109
provided library.java.jackson_dataformat_xml
114110
permitUnusedDeclared library.java.jackson_dataformat_xml

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteSubscriptionTable.java

Lines changed: 0 additions & 73 deletions
This file was deleted.

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTableProvider.java

Lines changed: 0 additions & 210 deletions
This file was deleted.

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTopicTable.java

Lines changed: 0 additions & 72 deletions
This file was deleted.

0 commit comments

Comments
 (0)