Package io.openlineage.client.dataset

Class Naming.PubSubNaming

java.lang.Object

io.openlineage.client.dataset.Naming.PubSubNaming

All Implemented Interfaces:

Naming.DatasetNaming

Enclosing class:

Naming

public static class Naming.PubSubNaming
extends Object
implements Naming.DatasetNaming

Naming implementation for Google Pub/Sub.

Namespace is fixed as "pubsub". Name format depends on the resource type:

• topic:{projectId}:{topicId}
• subscription:{projectId}:{subscriptionId}

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Naming.PubSubNaming.PubSubNamingBuilder
static enum	Naming.PubSubNaming.PubSubResourceType	Enum representing supported Pub/Sub resource types.

Constructor Summary

Constructors

Constructor	Description
PubSubNaming(Naming.PubSubNaming.PubSubResourceType resourceType, String projectId, String resourceId)	Constructs a Pub/Sub naming instance.

Method Summary

Modifier and Type	Method	Description
static Naming.PubSubNaming.PubSubNamingBuilder	builder()
String	getName()	Returns the dataset name specific to the platform format.
String	getNamespace()	Returns the dataset namespace (e.g., URI or ARN identifying the data source).

Methods inherited from class java.lang.Object

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

Constructor Details

PubSubNaming

public PubSubNaming(Naming.PubSubNaming.PubSubResourceType resourceType,
 String projectId,
 String resourceId)

Constructs a Pub/Sub naming instance.

Parameters:

resourceType - either TOPIC or SUBSCRIPTION

projectId - GCP project ID (non-empty)

resourceId - Topic ID or Subscription ID (non-empty)

Method Details

getNamespace

public String getNamespace()

Description copied from interface: Naming.DatasetNaming

Returns the dataset namespace (e.g., URI or ARN identifying the data source).

Specified by:

getNamespace in interface Naming.DatasetNaming

Returns:

the namespace string

getName

public String getName()

Description copied from interface: Naming.DatasetNaming

Returns the dataset name specific to the platform format.

Specified by:

getName in interface Naming.DatasetNaming

Returns:

the dataset name string

builder

public static Naming.PubSubNaming.PubSubNamingBuilder builder()