Package io.openlineage.client

Class OpenLineage.JobTypeJobFacetBuilder

java.lang.Object

io.openlineage.client.OpenLineage.JobTypeJobFacetBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.JobTypeJobFacet>

Enclosing class:

OpenLineage

public final class OpenLineage.JobTypeJobFacetBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.JobTypeJobFacet>

builder class for JobTypeJobFacet

Constructor Summary

Constructors

Constructor	Description
JobTypeJobFacetBuilder()

Method Summary

Modifier and Type	Method	Description
OpenLineage.JobTypeJobFacet	build()	build an instance of JobTypeJobFacet from the fields set in the builder
OpenLineage.JobTypeJobFacetBuilder	emissionPattern(OpenLineage.JobTypeJobFacetEmissionPattern emissionPattern)
OpenLineage.JobTypeJobFacetBuilder	integration(String integration)
OpenLineage.JobTypeJobFacetBuilder	jobType(String jobType)
OpenLineage.JobTypeJobFacetBuilder	processingType(String processingType)
OpenLineage.JobTypeJobFacetBuilder	put(String key, Object value)	add additional properties

Methods inherited from class java.lang.Object

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

Constructor Details

JobTypeJobFacetBuilder

public JobTypeJobFacetBuilder()

Method Details

processingType

public OpenLineage.JobTypeJobFacetBuilder processingType(String processingType)

Parameters:

processingType - Job processing type: BATCH (finite jobs with clear start/end), STREAMING (continuous jobs processing data streams), or SERVICE (continuous long-running services). BATCH jobs are finite and emit START/COMPLETE/FAIL/ABORT events. STREAMING and SERVICE jobs are continuous with no natural completion point.

Returns:

this

integration

public OpenLineage.JobTypeJobFacetBuilder integration(String integration)

Parameters:

integration - OpenLineage integration type of this job: for example SPARK|DBT|AIRFLOW|FLINK

Returns:

this

jobType

public OpenLineage.JobTypeJobFacetBuilder jobType(String jobType)

Parameters:

jobType - Run type, for example: QUERY|COMMAND|DAG|TASK|JOB|MODEL. This is an integration-specific field.

Returns:

this

emissionPattern

public OpenLineage.JobTypeJobFacetBuilder emissionPattern(OpenLineage.JobTypeJobFacetEmissionPattern emissionPattern)

Parameters:

emissionPattern - Describes how and what the job emits in its events

Returns:

this

put

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

add additional properties

Parameters:

key - the additional property name

value - the additional property value

Returns:

this

build

public OpenLineage.JobTypeJobFacet build()

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

Specified by:

build in interface OpenLineage.Builder<OpenLineage.JobTypeJobFacet>

Returns:

the constructed type