Package io.openlineage.client

Class OpenLineage.GcpDataprocRunFacetBuilder

java.lang.Object

io.openlineage.client.OpenLineage.GcpDataprocRunFacetBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.GcpDataprocRunFacet>

Enclosing class:

OpenLineage

public final class OpenLineage.GcpDataprocRunFacetBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.GcpDataprocRunFacet>

builder class for GcpDataprocRunFacet

Constructor Summary

Constructors

Constructor	Description
GcpDataprocRunFacetBuilder()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

GcpDataprocRunFacetBuilder

public GcpDataprocRunFacetBuilder()

Method Details

appId

public OpenLineage.GcpDataprocRunFacetBuilder appId(String appId)

Parameters:

appId - Application ID set by the resource manager. For spark jobs, it is set in the spark configuration of the current context.

Returns:

this

appName

public OpenLineage.GcpDataprocRunFacetBuilder appName(String appName)

Parameters:

appName - App name which may be provided by the user, or some default is used by the resource manager. For spark jobs, it is set in the spark configuration of the current context.

Returns:

this

batchId

public OpenLineage.GcpDataprocRunFacetBuilder batchId(String batchId)

Parameters:

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

Returns:

this

batchUuid

public OpenLineage.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder projectId(String projectId)

Parameters:

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

Returns:

this

queryNodeName

public OpenLineage.GcpDataprocRunFacetBuilder 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

jobType

public OpenLineage.GcpDataprocRunFacetBuilder jobType(String jobType)

Parameters:

jobType - Identifies whether the process is a job (on a Dataproc cluster), a batch or a session.

Returns:

this

sessionId

public OpenLineage.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder 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.GcpDataprocRunFacetBuilder put(String key,
 Object value)

add additional properties

Parameters:

key - the additional property name

value - the additional property value

Returns:

this

build

public OpenLineage.GcpDataprocRunFacet build()

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

Specified by:

build in interface OpenLineage.Builder<OpenLineage.GcpDataprocRunFacet>

Returns:

the constructed type