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

Class OpenLineageProcessingEngineRunFacet

java.lang.Object

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

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

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageProcessingEngineRunFacet

public class OpenLineageProcessingEngineRunFacet
extends OpenLineageRunFacet

This class represents the processing_engine run facet. It identifies the engine (and OpenLineage adapter) that executed the run. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-1-1/ProcessingEngineRunFacet.json#/$defs/ProcessingEngineRunFacet.

Constructor Summary

Constructors

Constructor	Description
OpenLineageProcessingEngineRunFacet()	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.
String	getName()	Return the processing engine name, for example Airflow or Spark.
String	getOpenlineageAdapterVersion()	Return the version of the OpenLineage adapter package used by the engine.
String	getVersion()	Return the processing engine version, for example the Airflow or Spark version.
int	hashCode()	Return hash code based on properties.
void	setName(String name)	Set up the processing engine name, for example Airflow or Spark.
void	setOpenlineageAdapterVersion(String openlineageAdapterVersion)	Set up the version of the OpenLineage adapter package used by the engine.
void	setVersion(String version)	Set up the processing engine version, for example the Airflow or Spark version.
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

OpenLineageProcessingEngineRunFacet

public OpenLineageProcessingEngineRunFacet()

Default constructor

Method Details

getVersion

public String getVersion()

Return the processing engine version, for example the Airflow or Spark version.

Returns:

string

setVersion

public void setVersion(String version)

Set up the processing engine version, for example the Airflow or Spark version.

Parameters:

version - string

getName

public String getName()

Return the processing engine name, for example Airflow or Spark.

Returns:

string

setName

public void setName(String name)

Set up the processing engine name, for example Airflow or Spark.

Parameters:

name - string

getOpenlineageAdapterVersion

public String getOpenlineageAdapterVersion()

Return the version of the OpenLineage adapter package used by the engine.

Returns:

string

setOpenlineageAdapterVersion

public void setOpenlineageAdapterVersion(String openlineageAdapterVersion)

Set up the version of the OpenLineage adapter package used by the engine.

Parameters:

openlineageAdapterVersion - 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