com.google.cloud.dataflow.sdk.io

Class PubsubIO

java.lang.Object

com.google.cloud.dataflow.sdk.io.PubsubIO

public class PubsubIO
extends java.lang.Object

[Whitelisting Required] Read and Write transforms for Pub/Sub streams. These transforms create and consume unbounded PCollections.

Important: PubsubIO is experimental. It is not supported by the DirectPipelineRunner and is only supported in the DataflowPipelineRunner for users whitelisted in a streaming early access program and who enable StreamingOptions.setStreaming(boolean).

You should expect this class to change significantly in future versions of the SDK or be removed entirely.

Nested Class Summary

Nested Classes

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.

Constructor Summary

Constructors

Constructor and Description
PubsubIO()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubIO

public PubsubIO()