public class PubsubIO extends Object
PTransforms for Pub/Sub streams. These transforms create
and consume unbounded PCollections.
PipelineRunner that is
used to execute the Dataflow job. Please refer to the documentation of corresponding
PipelineRunners for more details.| Modifier and Type | Class and Description |
|---|---|
static class |
PubsubIO.PubsubSubscription
Class representing a Pubsub Subscription.
|
static class |
PubsubIO.PubsubTopic
Class representing a Pubsub Topic.
|
static class |
PubsubIO.Read
A
PTransform that continuously reads from a Pubsub stream and
returns a PCollection<String> containing the items from
the stream. |
static class |
PubsubIO.Write
A
PTransform that continuously writes a
PCollection<String> to a Pubsub stream. |
| Modifier and Type | Field and Description |
|---|---|
static Coder<String> |
DEFAULT_PUBSUB_CODER |
| Constructor and Description |
|---|
PubsubIO() |