Package org.odpi.openmetadata.frameworks.integration.openlineage

Class OpenLineageJobDependenciesRunFacet

java.lang.Object

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageFacet

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageRunFacet

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageJobDependenciesRunFacet

public class OpenLineageJobDependenciesRunFacet
extends OpenLineageRunFacet

This class represents the jobDependencies run facet. It records the job runs that must complete before this run starts, and those that start after it completes. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-0-1/JobDependenciesRunFacet.json#/$defs/JobDependenciesRunFacet.

Constructor Summary

Constructors

Constructor	Description
OpenLineageJobDependenciesRunFacet()	Default constructor

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object objectToCompare)	Compare the values of the supplied object with those stored in the current object.
List<OpenLineageJobDependenciesRunFacetDependency>	getDownstream()	Return the job runs that will start after completion of the current run.
String	getTriggerRule()	Return the condition under which this job will run based on the status of its upstream jobs.
List<OpenLineageJobDependenciesRunFacetDependency>	getUpstream()	Return the job runs that must complete before the current run can start.
int	hashCode()	Return hash code based on properties.
void	setDownstream(List<OpenLineageJobDependenciesRunFacetDependency> downstream)	Set up the job runs that will start after completion of the current run.
void	setTriggerRule(String triggerRule)	Set up the condition under which this job will run based on the status of its upstream jobs.
void	setUpstream(List<OpenLineageJobDependenciesRunFacetDependency> upstream)	Set up the job runs that must complete before the current run can start.
String	toString()	Standard toString method.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageFacet

get_producer, get_schemaURL, getAdditionalProperties, set_producer, set_schemaURL, setAdditionalProperties, setAdditionalProperty

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

OpenLineageJobDependenciesRunFacet

public OpenLineageJobDependenciesRunFacet()

Default constructor

Method Details

getUpstream

public List<OpenLineageJobDependenciesRunFacetDependency> getUpstream()

Return the job runs that must complete before the current run can start.

Returns:

list

setUpstream

public void setUpstream(List<OpenLineageJobDependenciesRunFacetDependency> upstream)

Set up the job runs that must complete before the current run can start.

Parameters:

upstream - list

getDownstream

public List<OpenLineageJobDependenciesRunFacetDependency> getDownstream()

Return the job runs that will start after completion of the current run.

Returns:

list

setDownstream

public void setDownstream(List<OpenLineageJobDependenciesRunFacetDependency> downstream)

Set up the job runs that will start after completion of the current run.

Parameters:

downstream - list

getTriggerRule

public String getTriggerRule()

Return the condition under which this job will run based on the status of its upstream jobs.

Returns:

string

setTriggerRule

public void setTriggerRule(String triggerRule)

Set up the condition under which this job will run based on the status of its upstream jobs.

Parameters:

triggerRule - string

toString

public String toString()

Standard toString method.

Overrides:

toString in class OpenLineageRunFacet

Returns:

print out of variables in a JSON-style

equals

public boolean equals(Object objectToCompare)

Compare the values of the supplied object with those stored in the current object.

Overrides:

equals in class OpenLineageFacet

Parameters:

objectToCompare - supplied object

Returns:

boolean result of comparison

hashCode

public int hashCode()

Return hash code based on properties.

Overrides:

hashCode in class OpenLineageFacet

Returns:

int