Package io.openlineage.client

Class OpenLineage.JobTypeJobFacet

java.lang.Object

io.openlineage.client.OpenLineage.JobTypeJobFacet

All Implemented Interfaces:

OpenLineage.JobFacet

Enclosing class:

OpenLineage

public static final class OpenLineage.JobTypeJobFacet
extends Object
implements OpenLineage.JobFacet

model class for JobTypeJobFacet

Method Summary

Modifier and Type	Method	Description
Boolean	get_deleted()
URI	get_producer()
URI	get_schemaURL()
Map<String,Object>	getAdditionalProperties()
String	getIntegration()
String	getJobType()
String	getProcessingType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openlineage.client.OpenLineage.JobFacet

isDeleted

Method Details

get_producer

public URI get_producer()

Specified by:

get_producer in interface OpenLineage.JobFacet

Returns:

URI identifying the producer of this metadata. For example this could be a git url with a given tag or sha

get_schemaURL

public URI get_schemaURL()

Specified by:

get_schemaURL in interface OpenLineage.JobFacet

Returns:

The JSON Pointer (https://tools.ietf.org/html/rfc6901) URL to the corresponding version of the schema definition for this facet

get_deleted

public Boolean get_deleted()

Specified by:

get_deleted in interface OpenLineage.JobFacet

Returns:

set to true to delete a facet

getProcessingType

public String getProcessingType()

Returns:

Job processing type like: BATCH or STREAMING

getIntegration

public String getIntegration()

Returns:

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

getJobType

public String getJobType()

Returns:

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

getAdditionalProperties

public Map<String,Object> getAdditionalProperties()

Specified by:

getAdditionalProperties in interface OpenLineage.JobFacet

Returns:

additional properties