com.google.cloud.dataflow.sdk.io

Class PubsubIO.Write

java.lang.Object

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

Enclosing class:

PubsubIO

public static class PubsubIO.Write
extends java.lang.Object

A PTransform that continuously writes a PCollection<String> to a Pubsub stream.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubIO.Write.Bound A PTransfrom that writes a unbounded PCollection<String> to a PubSub stream.

Constructor Summary

Constructors

Constructor and Description
PubsubIO.Write()

Method Summary

Methods

Modifier and Type	Method and Description
static PubsubIO.Write.Bound	named(java.lang.String name)
static PubsubIO.Write.Bound	topic(java.lang.String topic) The topic to publish to.

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubIO.Write

public PubsubIO.Write()

Method Detail

named

public static PubsubIO.Write.Bound named(java.lang.String name)

topic

public static PubsubIO.Write.Bound topic(java.lang.String topic)

The topic to publish to. Cloud Pubsub topic names should be /topics/<project>/<topic>, where <project> is the name of the publishing project.