Class SinkInfo.Destination.TopicDestination (3.9.0)

public static final class SinkInfo.Destination.TopicDestination extends SinkInfo.Destination

Class for specifying a Google Cloud BigQuery dataset as destination for the sink.

Inheritance

Object > SinkInfo.Destination > SinkInfo.Destination.TopicDestination

Static Methods

of(String topic)

public static SinkInfo.Destination.TopicDestination of(String topic)

Creates a DatasetDestination object given the name of the topic to be used as sink destination. Topic is assumed to reside in the default project.

Parameter
NameDescription
topicString
Returns
TypeDescription
SinkInfo.Destination.TopicDestination

of(String project, String topic)

public static SinkInfo.Destination.TopicDestination of(String project, String topic)

Creates a TopicDestination object given the name of the project and topic to be used as sink destination.

Parameters
NameDescription
projectString
topicString
Returns
TypeDescription
SinkInfo.Destination.TopicDestination

Methods

equals(Object obj)

public boolean equals(Object obj)
Parameter
NameDescription
objObject
Returns
TypeDescription
boolean
Overrides

getProject()

public String getProject()

Returns the name of the project where the Google Cloud Pub/Sub topic resides. If null, the default project is used.

Returns
TypeDescription
String

getTopic()

public String getTopic()

Returns the name of the Google Cloud Pub/Sub topic this destination represents.

Returns
TypeDescription
String

hashCode()

public int hashCode()
Returns
TypeDescription
int
Overrides

toString()

public String toString()
Returns
TypeDescription
String
Overrides