Class SinkInfo.Destination.TopicDestination (3.12.1)

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

Inherited Members

SinkInfo.Destination.getType()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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

Name	Description
topic	`String`

Returns

Type	Description
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

Name	Description
project	`String`
topic	`String`

Returns

Type	Description
SinkInfo.Destination.TopicDestination

Methods

equals(Object obj)

public boolean equals(Object obj)

Parameter

Name	Description
obj	`Object`

Returns

Type	Description
boolean

Overrides

Object.equals(Object)

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

Type	Description
String

getTopic()

public String getTopic()

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

Returns

Type	Description
String

hashCode()

public int hashCode()

Returns

Type	Description
int

Overrides

Object.hashCode()

toString()

public String toString()

Returns

Type	Description
String

Overrides

Object.toString()