Package io.openlineage.client

Class OpenLineage.GcpDataprocSparkRunFacetBuilder

java.lang.Object

io.openlineage.client.OpenLineage.GcpDataprocSparkRunFacetBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.GcpDataprocSparkRunFacet>

Enclosing class:

OpenLineage

public final class OpenLineage.GcpDataprocSparkRunFacetBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.GcpDataprocSparkRunFacet>

builder class for GcpDataprocSparkRunFacet

Constructor Summary

Constructors

Constructor	Description
GcpDataprocSparkRunFacetBuilder()

Method Summary

Modifier and Type	Method	Description
OpenLineage.GcpDataprocSparkRunFacetBuilder	appId(String appId)
OpenLineage.GcpDataprocSparkRunFacetBuilder	appName(String appName)
OpenLineage.GcpDataprocSparkRunFacetBuilder	batchId(String batchId)
OpenLineage.GcpDataprocSparkRunFacetBuilder	batchUuid(String batchUuid)
OpenLineage.GcpDataprocSparkRunFacet	build()	build an instance of GcpDataprocSparkRunFacet from the fields set in the builder
OpenLineage.GcpDataprocSparkRunFacetBuilder	clusterName(String clusterName)
OpenLineage.GcpDataprocSparkRunFacetBuilder	clusterUuid(String clusterUuid)
OpenLineage.GcpDataprocSparkRunFacetBuilder	jobId(String jobId)
OpenLineage.GcpDataprocSparkRunFacetBuilder	jobUuid(String jobUuid)
OpenLineage.GcpDataprocSparkRunFacetBuilder	projectId(String projectId)
OpenLineage.GcpDataprocSparkRunFacetBuilder	put(String key, Object value)	add additional properties
OpenLineage.GcpDataprocSparkRunFacetBuilder	queryNodeName(String queryNodeName)
OpenLineage.GcpDataprocSparkRunFacetBuilder	sessionId(String sessionId)
OpenLineage.GcpDataprocSparkRunFacetBuilder	sessionUuid(String sessionUuid)

Methods inherited from class java.lang.Object

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

Constructor Details

GcpDataprocSparkRunFacetBuilder

public GcpDataprocSparkRunFacetBuilder()

Method Details

appId

public OpenLineage.GcpDataprocSparkRunFacetBuilder appId(String appId)

Parameters:

appId - Application ID set in the spark configuration of the current context. Its format depends on the resource manager.

Returns:

this

appName

public OpenLineage.GcpDataprocSparkRunFacetBuilder appName(String appName)

Parameters:

appName - App name set in the spark configuration of the current context. It may be provided by the user.

Returns:

this

batchId

public OpenLineage.GcpDataprocSparkRunFacetBuilder batchId(String batchId)

Parameters:

batchId - Populated only for Dataproc serverless batches. The resource id of the batch.

Returns:

this

batchUuid

public OpenLineage.GcpDataprocSparkRunFacetBuilder batchUuid(String batchUuid)

Parameters:

batchUuid - Populated only for Dataproc serverless batches. A UUID generated by the service when it creates the batch.

Returns:

this

clusterName

public OpenLineage.GcpDataprocSparkRunFacetBuilder clusterName(String clusterName)

Parameters:

clusterName - Populated only for Dataproc GCE workloads. The cluster name is unique within a GCP project.

Returns:

this

clusterUuid

public OpenLineage.GcpDataprocSparkRunFacetBuilder clusterUuid(String clusterUuid)

Parameters:

clusterUuid - Populated only for Dataproc GCE workloads. A UUID generated by the service at the time of cluster creation.

Returns:

this

jobId

public OpenLineage.GcpDataprocSparkRunFacetBuilder jobId(String jobId)

Parameters:

jobId - Populated only for Dataproc GCE workloads. If not specified by the user, the job ID will be provided by the service.

Returns:

this

jobUuid

public OpenLineage.GcpDataprocSparkRunFacetBuilder jobUuid(String jobUuid)

Parameters:

jobUuid - Populated only for Dataproc GCE workloads. A UUID that uniquely identifies a job within the project over time.

Returns:

this

projectId

public OpenLineage.GcpDataprocSparkRunFacetBuilder projectId(String projectId)

Parameters:

projectId - The GCP project ID that the resource belongs to.

Returns:

this

queryNodeName

public OpenLineage.GcpDataprocSparkRunFacetBuilder queryNodeName(String queryNodeName)

Parameters:

queryNodeName - The name of the query node in the executed Spark Plan. Often used to describe the command being executed.

Returns:

this

sessionId

public OpenLineage.GcpDataprocSparkRunFacetBuilder sessionId(String sessionId)

Parameters:

sessionId - Populated only for Dataproc serverless interactive sessions. The resource id of the session, used for URL generation.

Returns:

this

sessionUuid

public OpenLineage.GcpDataprocSparkRunFacetBuilder sessionUuid(String sessionUuid)

Parameters:

sessionUuid - Populated only for Dataproc serverless interactive sessions. A UUID generated by the service when it creates the session.

Returns:

this

put

public OpenLineage.GcpDataprocSparkRunFacetBuilder put(String key,
 Object value)

add additional properties

Parameters:

key - the additional property name

value - the additional property value

Returns:

this

build

public OpenLineage.GcpDataprocSparkRunFacet build()

build an instance of GcpDataprocSparkRunFacet from the fields set in the builder

Specified by:

build in interface OpenLineage.Builder<OpenLineage.GcpDataprocSparkRunFacet>

Returns:

the constructed type