PubsubIO (Apache Beam 2.44.0)

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.
Updates to the I/O connector code
For any significant updates to this I/O connector, please consider involving corresponding code reviewers mentioned here.

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 methods.
`static class`	`PubsubIO.Write<T>` Implementation of write methods.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static PubsubIO.Read<GenericRecord>`	`readAvroGenericRecords(Schema avroSchema)` Returns a `PTransform` that continuously reads binary encoded Avro messages into the Avro `GenericRecord` type.
`static <T> 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 <T> PubsubIO.Read<T>`	`readAvrosWithBeamSchema(java.lang.Class<T> clazz)` Returns a `PTransform` that continuously reads binary encoded Avro messages of the specific type.
`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 PubsubIO.Read<PubsubMessage>`	`readMessagesWithAttributesAndMessageId()` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream.
`static PubsubIO.Read<PubsubMessage>`	`readMessagesWithAttributesAndMessageIdAndOrderingKey()` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream.
`static <T> PubsubIO.Read<T>`	`readMessagesWithCoderAndParseFn(Coder<T> coder, SimpleFunction<PubsubMessage,T> parseFn)` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream, mapping each `PubsubMessage` into type T using the supplied parse function and coder.
`static PubsubIO.Read<PubsubMessage>`	`readMessagesWithMessageId()` Returns A `PTransform` that continuously reads from a Google Cloud Pub/Sub stream.
`static PubsubIO.Read<DynamicMessage>`	`readProtoDynamicMessages(Descriptors.Descriptor descriptor)` Similar to `readProtoDynamicMessages(ProtoDomain, String)` but for when the `Descriptors.Descriptor` is already known.
`static PubsubIO.Read<DynamicMessage>`	`readProtoDynamicMessages(ProtoDomain domain, java.lang.String fullMessageName)` Returns a `PTransform` that continuously reads binary encoded protobuf messages for the type specified by `fullMessageName`.
`static <T extends 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> 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 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.
  - readMessagesWithMessageId
```
public static PubsubIO.Read<PubsubMessage> readMessagesWithMessageId()
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream. The messages will only contain a payload with the messageId from PubSub, 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.
  - readMessagesWithAttributesAndMessageId
```
public static PubsubIO.Read<PubsubMessage> readMessagesWithAttributesAndMessageId()
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream. The messages will contain both a payload and attributes, along with the messageId from PubSub.
  - readMessagesWithAttributesAndMessageIdAndOrderingKey
```
public static PubsubIO.Read<PubsubMessage> readMessagesWithAttributesAndMessageIdAndOrderingKey()
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream. The messages will contain a payload, attributes, along with the messageId and {PubsubMessage#getOrderingKey() orderingKey} from PubSub.
  - 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 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.
  - readProtoDynamicMessages
```
@Experimental(value=SCHEMAS)
public static PubsubIO.Read<DynamicMessage> readProtoDynamicMessages(ProtoDomain domain,
                                                                                                  java.lang.String fullMessageName)
```
    Returns a PTransform that continuously reads binary encoded protobuf messages for the type specified by fullMessageName.
    This is primarily here for cases where the message type cannot be known at compile time. If it can be known, prefer readProtos(Class), as DynamicMessage tends to perform worse than concrete types.
    Beam will infer a schema for the DynamicMessage schema. Note that some proto schema features are not supported by all sinks.
    
    Parameters:
    
    domain - The ProtoDomain that contains the target message and its dependencies.
    
    fullMessageName - The full name of the message for lookup in domain.
  - readProtoDynamicMessages
```
@Experimental(value=SCHEMAS)
public static PubsubIO.Read<DynamicMessage> readProtoDynamicMessages(Descriptors.Descriptor descriptor)
```
    Similar to readProtoDynamicMessages(ProtoDomain, String) but for when the Descriptors.Descriptor is already known.
  - readAvros
```
public static <T> 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.
  - readMessagesWithCoderAndParseFn
```
public static <T> PubsubIO.Read<T> readMessagesWithCoderAndParseFn(Coder<T> coder,
                                                                   SimpleFunction<PubsubMessage,T> parseFn)
```
    Returns A PTransform that continuously reads from a Google Cloud Pub/Sub stream, mapping each PubsubMessage into type T using the supplied parse function and coder.
  - readAvroGenericRecords
```
@Experimental(value=SCHEMAS)
public static PubsubIO.Read<GenericRecord> readAvroGenericRecords(Schema avroSchema)
```
    Returns a PTransform that continuously reads binary encoded Avro messages into the Avro GenericRecord type.
    Beam will infer a schema for the Avro schema. This allows the output to be used by SQL and by the schema-transform library.
  - readAvrosWithBeamSchema
```
@Experimental(value=SCHEMAS)
public static <T> PubsubIO.Read<T> readAvrosWithBeamSchema(java.lang.Class<T> clazz)
```
    Returns a PTransform that continuously reads binary encoded Avro messages of the specific type.
    Beam will infer a schema for the Avro schema. This allows the output to be used by SQL and by the schema-transform library.
  - 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 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> 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

Updates to the I/O connector code

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

readMessages

readMessagesWithMessageId

readMessagesWithAttributes

readMessagesWithAttributesAndMessageId

readMessagesWithAttributesAndMessageIdAndOrderingKey

readStrings

readProtos

readProtoDynamicMessages

readProtoDynamicMessages

readAvros

readMessagesWithCoderAndParseFn

readAvroGenericRecords

readAvrosWithBeamSchema

writeMessages

writeStrings

writeProtos

writeAvros