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 only usable with the DataflowPipelineRunner and requires StreamingOptions.setStreaming(boolean) to be enabled.

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.

Field Summary

Fields

Modifier and Type	Field and Description
static Coder<java.lang.String>	DEFAULT_PUBSUB_CODER

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

Field Detail

DEFAULT_PUBSUB_CODER

public static final Coder<java.lang.String> DEFAULT_PUBSUB_CODER

Constructor Detail

PubsubIO

public PubsubIO()