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