Skip to content

Commit 246e4e7

Browse files
feat: remove beam I/O from repo and redirect to beam (#479)
1 parent 4259835 commit 246e4e7

Some content is hidden

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

43 files changed

+8
-3569
lines changed

pom.xml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,6 @@
121121
<module>google-cloud-pubsublite</module>
122122
<module>grpc-google-cloud-pubsublite-v1</module>
123123
<module>proto-google-cloud-pubsublite-v1</module>
124-
<module>pubsublite-beam-io</module>
125124
</modules>
126125

127126
<profiles>

pubsublite-beam-io/EnableAutoValue.txt

Whitespace-only changes.

pubsublite-beam-io/README.md

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,17 +3,18 @@
33
1. Add the following to your POM file to download the Pub/Sub Lite I/O.
44
```xml
55
<dependency>
6-
<groupId>com.google.cloud</groupId>
7-
<artifactId>pubsublite-beam-io</artifactId>
8-
<version>0.6.0</version>
6+
<groupId>org.apache.beam</groupId>
7+
<artifactId>beam-sdks-java-io-google-cloud-platform</artifactId>
8+
<version>2.27.0</version>
99
</dependency>
1010
```
1111
1. Create a topic using `gcloud pubsub lite-topics create`
1212
1. Write some messages using:
1313

1414
```java
15-
import com.google.cloud.pubsublite.beam.PubsubLiteIO;
16-
import com.google.cloud.pubsublite.beam.PublisherOptions;
15+
import org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteIO;
16+
import org.apache.beam.sdk.io.gcp.pubsublite.PublisherOptions;
17+
import com.google.cloud.pubsublite.proto.PubSubMessage;
1718
import com.google.cloud.pubsublite.*;
1819

1920
...
@@ -23,7 +24,7 @@
2324

2425
...
2526

26-
PCollection<Message> messages = ...;
27+
PCollection<PubSubMessage> messages = ...;
2728
messages.apply("Write messages", PubsubLiteIO.write(
2829
PublisherOptions.newBuilder()
2930
.setTopicPath(TopicPath.newBuilder()
@@ -39,6 +40,7 @@
3940
```java
4041
import com.google.cloud.pubsublite.beam.PubsubLiteIO;
4142
import com.google.cloud.pubsublite.beam.SubscriberOptions;
43+
import com.google.cloud.pubsublite.proto.SequencedMessage;
4244
import com.google.cloud.pubsublite.*;
4345
import com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings;
4446

pubsublite-beam-io/clirr-ignored-differences.xml

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

pubsublite-beam-io/pom.xml

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

pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/AddUuidsTransform.java

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

0 commit comments

Comments
 (0)