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

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

PubsubIO is experimental. It is only usable with the DataflowPipelineRunner and requires StreamingOptions.setStreaming(boolean) to be enabled.

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()