PubsubIO

java.lang.Object
- org.apache.beam.sdk.io.gcp.pubsub.PubsubIO

```
public class PubsubIO
extends java.lang.Object
```
Read and Write PTransforms for Cloud Pub/Sub streams. These transforms create and consume unbounded PCollections.
Using local emulator

In order to use local emulator for Pubsub you should use PubsubOptions#setPubsubRootUrl(String) method to set host and port of your local emulator.
Permissions

Permission requirements depend on the PipelineRunner that is used to execute the Beam pipeline. Please refer to the documentation of corresponding PipelineRunners for more details.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`PubsubIO.PubsubSubscription` Class representing a Cloud Pub/Sub Subscription.
`static class`	`PubsubIO.PubsubTopic` Class representing a Cloud Pub/Sub Topic.
`static class`	`PubsubIO.Read<T>` Implementation of `read()`.
`static class`	`PubsubIO.Write<T>` Implementation of `write()`.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static <T extends com.google.protobuf.Message> PubsubIO.Read<T>`	`readAvros(java.lang.Class<T> clazz)` Returns A `PTransform` that continuously reads binary encoded Avro messages of the given type from a Google Cloud Pub/Sub stream.
`static PubsubIO.Read<PubsubMessage>`	`readMessages()` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream.
`static PubsubIO.Read<PubsubMessage>`	`readMessagesWithAttributes()` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream.
`static <T extends com.google.protobuf.Message> PubsubIO.Read<T>`	`readProtos(java.lang.Class<T> messageClass)` Returns A `PTransform` that continuously reads binary encoded protobuf messages of the given type from a Google Cloud Pub/Sub stream.
`static PubsubIO.Read<java.lang.String>`	`readStrings()` Returns A `PTransform` that continuously reads UTF-8 encoded strings from a Google Cloud Pub/Sub stream.
`static <T extends com.google.protobuf.Message> PubsubIO.Write<T>`	`writeAvros(java.lang.Class<T> clazz)` Returns A `PTransform` that writes binary encoded Avro messages of a given type to a Google Cloud Pub/Sub stream.
`static PubsubIO.Write<PubsubMessage>`	`writeMessages()` Returns A `PTransform` that writes to a Google Cloud Pub/Sub stream.
`static <T extends com.google.protobuf.Message> PubsubIO.Write<T>`	`writeProtos(java.lang.Class<T> messageClass)` Returns A `PTransform` that writes binary encoded protobuf messages of a given type to a Google Cloud Pub/Sub stream.
`static PubsubIO.Write<java.lang.String>`	`writeStrings()` Returns A `PTransform` that writes UTF-8 encoded strings to a Google Cloud Pub/Sub stream.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - readMessages
```
public static PubsubIO.Read<PubsubMessage> readMessages()
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream. The messages will only contain a payload, but no attributes.
  - readMessagesWithAttributes
```
public static PubsubIO.Read<PubsubMessage> readMessagesWithAttributes()
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream. The messages will contain both a payload and attributes.
  - readStrings
```
public static PubsubIO.Read<java.lang.String> readStrings()
```
    Returns A PTransform that continuously reads UTF-8 encoded strings from a Google Cloud Pub/Sub stream.
  - readProtos
```
public static <T extends com.google.protobuf.Message> PubsubIO.Read<T> readProtos(java.lang.Class<T> messageClass)
```
    Returns A PTransform that continuously reads binary encoded protobuf messages of the given type from a Google Cloud Pub/Sub stream.
  - readAvros
```
public static <T extends com.google.protobuf.Message> PubsubIO.Read<T> readAvros(java.lang.Class<T> clazz)
```
    Returns A PTransform that continuously reads binary encoded Avro messages of the given type from a Google Cloud Pub/Sub stream.
  - writeMessages
```
public static PubsubIO.Write<PubsubMessage> writeMessages()
```
    Returns A PTransform that writes to a Google Cloud Pub/Sub stream.
  - writeStrings
```
public static PubsubIO.Write<java.lang.String> writeStrings()
```
    Returns A PTransform that writes UTF-8 encoded strings to a Google Cloud Pub/Sub stream.
  - writeProtos
```
public static <T extends com.google.protobuf.Message> PubsubIO.Write<T> writeProtos(java.lang.Class<T> messageClass)
```
    Returns A PTransform that writes binary encoded protobuf messages of a given type to a Google Cloud Pub/Sub stream.
  - writeAvros
```
public static <T extends com.google.protobuf.Message> PubsubIO.Write<T> writeAvros(java.lang.Class<T> clazz)
```
    Returns A PTransform that writes binary encoded Avro messages of a given type to a Google Cloud Pub/Sub stream.

Class PubsubIO

Using local emulator

Permissions

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

readMessages

readMessagesWithAttributes

readStrings

readProtos

readAvros

writeMessages

writeStrings

writeProtos

writeAvros