Package io.openlineage.client

Class OpenLineage.GcpComposerJobFacetBuilder

java.lang.Object

io.openlineage.client.OpenLineage.GcpComposerJobFacetBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.GcpComposerJobFacet>

Enclosing class:

OpenLineage

public final class OpenLineage.GcpComposerJobFacetBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.GcpComposerJobFacet>

builder class for GcpComposerJobFacet

Constructor Summary

Constructors

Constructor	Description
GcpComposerJobFacetBuilder()

Method Summary

Modifier and Type	Method	Description
OpenLineage.GcpComposerJobFacetBuilder	airflowVersion(String airflowVersion)
OpenLineage.GcpComposerJobFacet	build()	build an instance of GcpComposerJobFacet from the fields set in the builder
OpenLineage.GcpComposerJobFacetBuilder	composerVersion(String composerVersion)
OpenLineage.GcpComposerJobFacetBuilder	dagId(String dagId)
OpenLineage.GcpComposerJobFacetBuilder	environmentName(String environmentName)
OpenLineage.GcpComposerJobFacetBuilder	operator(String operator)
OpenLineage.GcpComposerJobFacetBuilder	put(String key, Object value)	add additional properties
OpenLineage.GcpComposerJobFacetBuilder	taskId(String taskId)

Methods inherited from class java.lang.Object

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

Constructor Details

GcpComposerJobFacetBuilder

public GcpComposerJobFacetBuilder()

Method Details

environmentName

public OpenLineage.GcpComposerJobFacetBuilder environmentName(String environmentName)

Parameters:

environmentName - Cloud Composer Environment name

Returns:

this

dagId

public OpenLineage.GcpComposerJobFacetBuilder dagId(String dagId)

Parameters:

dagId - The id of the DAG

Returns:

this

operator

public OpenLineage.GcpComposerJobFacetBuilder operator(String operator)

Parameters:

operator - Operator class name. Only present for tasks, not for DAGs. For example `PythonOperator`

Returns:

this

taskId

public OpenLineage.GcpComposerJobFacetBuilder taskId(String taskId)

Parameters:

taskId - The id of the task. Only present for tasks, not for DAGs

Returns:

this

airflowVersion

public OpenLineage.GcpComposerJobFacetBuilder airflowVersion(String airflowVersion)

Parameters:

airflowVersion - Version of Airflow, suffixed by `+composer`

Returns:

this

composerVersion

public OpenLineage.GcpComposerJobFacetBuilder composerVersion(String composerVersion)

Parameters:

composerVersion - Version of the Cloud Composer environment

Returns:

this

put

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

add additional properties

Parameters:

key - the additional property name

value - the additional property value

Returns:

this

build

public OpenLineage.GcpComposerJobFacet build()

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

Specified by:

build in interface OpenLineage.Builder<OpenLineage.GcpComposerJobFacet>

Returns:

the constructed type