Package io.openlineage.client

Class OpenLineage.JobDependencyBuilder

java.lang.Object

io.openlineage.client.OpenLineage.JobDependencyBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.JobDependency>

Enclosing class:

OpenLineage

public static final class OpenLineage.JobDependencyBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.JobDependency>

builder class for JobDependency

Constructor Summary

Constructors

Constructor	Description
JobDependencyBuilder()

Method Summary

Modifier and Type	Method	Description
OpenLineage.JobDependency	build()	build an instance of JobDependency from the fields set in the builder
OpenLineage.JobDependencyBuilder	dependency_type(String dependency_type)
OpenLineage.JobDependencyBuilder	job(OpenLineage.JobIdentifier job)
OpenLineage.JobDependencyBuilder	run(OpenLineage.RunIdentifier run)
OpenLineage.JobDependencyBuilder	sequence_trigger_rule(String sequence_trigger_rule)
OpenLineage.JobDependencyBuilder	status_trigger_rule(String status_trigger_rule)

Methods inherited from class java.lang.Object

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

Constructor Details

JobDependencyBuilder

public JobDependencyBuilder()

Method Details

job

public OpenLineage.JobDependencyBuilder job(OpenLineage.JobIdentifier job)

Parameters:

job - the job

Returns:

this

run

public OpenLineage.JobDependencyBuilder run(OpenLineage.RunIdentifier run)

Parameters:

run - the run

Returns:

this

dependency_type

public OpenLineage.JobDependencyBuilder dependency_type(String dependency_type)

Parameters:

dependency_type - Used to describe whether the upstream job directly triggers the downstream job, or whether the dependency is implicit (e.g. time-based).

Returns:

this

sequence_trigger_rule

public OpenLineage.JobDependencyBuilder sequence_trigger_rule(String sequence_trigger_rule)

Parameters:

sequence_trigger_rule - Used to describe the exact sequence condition on which the downstream job can be executed (FINISH_TO_START - downstream job can start when upstream finished; FINISH_TO_FINISH - job executions can overlap, but need to finish in specified order; START_TO_START - jobs need to start at the same time in parallel).

Returns:

this

status_trigger_rule

public OpenLineage.JobDependencyBuilder status_trigger_rule(String status_trigger_rule)

Parameters:

status_trigger_rule - Used to describe if the downstream job should be run based on the status of the upstream job.

Returns:

this

build

public OpenLineage.JobDependency build()

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

Specified by:

build in interface OpenLineage.Builder<OpenLineage.JobDependency>

Returns:

the constructed type