Skip to content

Commit

Permalink
feat: remove beam I/O from repo and redirect to beam (#479)
Browse files Browse the repository at this point in the history
  • Loading branch information
dpcollins-google committed Feb 2, 2021
1 parent 4259835 commit 246e4e7
Show file tree
Hide file tree
Showing 43 changed files with 8 additions and 3,569 deletions.
1 change: 0 additions & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,6 @@
<module>google-cloud-pubsublite</module>
<module>grpc-google-cloud-pubsublite-v1</module>
<module>proto-google-cloud-pubsublite-v1</module>
<module>pubsublite-beam-io</module>
</modules>

<profiles>
Expand Down
Empty file.
14 changes: 8 additions & 6 deletions pubsublite-beam-io/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -3,17 +3,18 @@
1. Add the following to your POM file to download the Pub/Sub Lite I/O.
```xml
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>pubsublite-beam-io</artifactId>
<version>0.6.0</version>
<groupId>org.apache.beam</groupId>
<artifactId>beam-sdks-java-io-google-cloud-platform</artifactId>
<version>2.27.0</version>
</dependency>
```
1. Create a topic using `gcloud pubsub lite-topics create`
1. Write some messages using:

```java
import com.google.cloud.pubsublite.beam.PubsubLiteIO;
import com.google.cloud.pubsublite.beam.PublisherOptions;
import org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteIO;
import org.apache.beam.sdk.io.gcp.pubsublite.PublisherOptions;
import com.google.cloud.pubsublite.proto.PubSubMessage;
import com.google.cloud.pubsublite.*;

...
Expand All @@ -23,7 +24,7 @@

...

PCollection<Message> messages = ...;
PCollection<PubSubMessage> messages = ...;
messages.apply("Write messages", PubsubLiteIO.write(
PublisherOptions.newBuilder()
.setTopicPath(TopicPath.newBuilder()
Expand All @@ -39,6 +40,7 @@
```java
import com.google.cloud.pubsublite.beam.PubsubLiteIO;
import com.google.cloud.pubsublite.beam.SubscriberOptions;
import com.google.cloud.pubsublite.proto.SequencedMessage;
import com.google.cloud.pubsublite.*;
import com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings;

Expand Down
47 changes: 0 additions & 47 deletions pubsublite-beam-io/clirr-ignored-differences.xml

This file was deleted.

176 changes: 0 additions & 176 deletions pubsublite-beam-io/pom.xml

This file was deleted.

This file was deleted.

Loading

0 comments on commit 246e4e7

Please sign in to comment.