Google Cloud Dataflow SDK for Java, version 1.9.1
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 WritePTransform
s for Cloud Pub/Sub streams. These transforms create and consume unboundedPCollections
.Permissions
Permission requirements depend on the
PipelineRunner
that is used to execute the Dataflow job. Please refer to the documentation of correspondingPipelineRunners
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
APTransform
that continuously reads from a Cloud Pub/Sub stream and returns aPCollection
ofStrings
containing the items from the stream.static class
PubsubIO.Write
-
Field Summary
Fields Modifier and Type Field and Description static Coder<String>
DEFAULT_PUBSUB_CODER
The defaultCoder
used to translate to/from Cloud Pub/Sub messages.
-