public class PubsubIO extends Object
PTransforms for Pub/Sub streams. These transforms create
and consume unbounded PCollections.
PubsubIO is only usable
with the DataflowPipelineRunner
and requires
StreamingOptions.setStreaming(boolean)
to be enabled.
| Modifier and Type | Class and Description |
|---|---|
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.Validator
Utility class to validate topic and subscription names.
|
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() |