org.apache.beam.sdk.io.gcp.pubsub

Class PubsubIO.PubsubTopic

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PubsubIO

public static class PubsubIO.PubsubTopic
extends java.lang.Object
implements java.io.Serializable

Class representing a Cloud Pub/Sub Topic.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
java.lang.String	asPath() Returns the string representation of this topic as a path used in the Cloud Pub/Sub API.
java.lang.String	asV1Beta1Path() Deprecated. the v1beta1 API for Cloud Pub/Sub is deprecated.
java.lang.String	asV1Beta2Path() Deprecated. the v1beta2 API for Cloud Pub/Sub is deprecated.
static PubsubIO.PubsubTopic	fromPath(java.lang.String path) Creates a class representing a Cloud Pub/Sub topic from the specified topic path.

Methods inherited from class java.lang.Object

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

Method Detail

fromPath

public static PubsubIO.PubsubTopic fromPath(java.lang.String path)

Creates a class representing a Cloud Pub/Sub topic from the specified topic path.

Cloud Pub/Sub topic names should be of the form /topics/<project>/<topic>, where <project> is the name of the publishing project. The <topic> component must comply with the following requirements:

• Can only contain lowercase letters, numbers, dashes ('-'), underscores ('_') and periods ('.').
• Must be between 3 and 255 characters.
• Must begin with a letter.
• Must end with a letter or a number.
• Cannot begin with 'goog' prefix.

asV1Beta1Path

@Deprecated
public java.lang.String asV1Beta1Path()

Deprecated. the v1beta1 API for Cloud Pub/Sub is deprecated.

Returns the string representation of this topic as a path used in the Cloud Pub/Sub v1beta1 API.

asV1Beta2Path

@Deprecated
public java.lang.String asV1Beta2Path()

Deprecated. the v1beta2 API for Cloud Pub/Sub is deprecated.

Returns the string representation of this topic as a path used in the Cloud Pub/Sub v1beta2 API.

asPath

public java.lang.String asPath()

Returns the string representation of this topic as a path used in the Cloud Pub/Sub API.