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

Class OpenLineageExtractionErrorRunFacet

java.lang.Object

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

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

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageExtractionErrorRunFacet

public class OpenLineageExtractionErrorRunFacet
extends OpenLineageRunFacet

This class represents the extractionError run facet. It reports tasks whose lineage could not be extracted by the OpenLineage integration. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-1-2/ExtractionErrorRunFacet.json#/$defs/ExtractionErrorRunFacet.

Constructor Summary

Constructors

Constructor	Description
OpenLineageExtractionErrorRunFacet()	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<OpenLineageExtractionErrorRunFacetError>	getErrors()	Return the details of each extraction error.
Long	getFailedTasks()	Return the number of distinguishable tasks in the run that OpenLineage could not process successfully.
Long	getTotalTasks()	Return the number of distinguishable tasks in the run that were processed by OpenLineage, whether successfully or not.
int	hashCode()	Return hash code based on properties.
void	setErrors(List<OpenLineageExtractionErrorRunFacetError> errors)	Set up the details of each extraction error.
void	setFailedTasks(Long failedTasks)	Set up the number of distinguishable tasks in the run that OpenLineage could not process successfully.
void	setTotalTasks(Long totalTasks)	Set up the number of distinguishable tasks in the run that were processed by OpenLineage, whether successfully or not.
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

OpenLineageExtractionErrorRunFacet

public OpenLineageExtractionErrorRunFacet()

Default constructor

Method Details

getTotalTasks

public Long getTotalTasks()

Return the number of distinguishable tasks in the run that were processed by OpenLineage, whether successfully or not.

Returns:

long

setTotalTasks

public void setTotalTasks(Long totalTasks)

Set up the number of distinguishable tasks in the run that were processed by OpenLineage, whether successfully or not.

Parameters:

totalTasks - long

getFailedTasks

public Long getFailedTasks()

Return the number of distinguishable tasks in the run that OpenLineage could not process successfully.

Returns:

long

setFailedTasks

public void setFailedTasks(Long failedTasks)

Set up the number of distinguishable tasks in the run that OpenLineage could not process successfully.

Parameters:

failedTasks - long

getErrors

public List<OpenLineageExtractionErrorRunFacetError> getErrors()

Return the details of each extraction error.

Returns:

list

setErrors

public void setErrors(List<OpenLineageExtractionErrorRunFacetError> errors)

Set up the details of each extraction error.

Parameters:

errors - list

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