PubsubIO (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.io

Class PubsubIO

• java.lang.Object
• • com.google.cloud.dataflow.sdk.io.PubsubIO

• ---

  
  

  public class PubsubIO
  extends Object

  Read and Write PTransforms for Cloud Pub/Sub streams. These transforms create and consume unbounded PCollections.

  Permissions

  Permission requirements depend on the PipelineRunner that is used to execute the Dataflow job. 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 A PTransform that continuously reads from a Cloud Pub/Sub stream and returns a PCollection of Strings containing the items from the stream.
    static class	PubsubIO.Write A PTransform that continuously writes a PCollection of Strings to a Cloud Pub/Sub stream.

  • Field Summary

    Fields 

    Modifier and Type	Field and Description
    static Coder<String>	DEFAULT_PUBSUB_CODER The default Coder used to translate to/from Cloud Pub/Sub messages.

  • Method Summary

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • Field Detail

    • DEFAULT_PUBSUB_CODER

      public static final Coder<String> DEFAULT_PUBSUB_CODER

      The default Coder used to translate to/from Cloud Pub/Sub messages.