Package io.openlineage.client

Class OpenLineage.GcpComposerJobFacet

java.lang.Object
io.openlineage.client.OpenLineage.GcpComposerJobFacet
All Implemented Interfaces:
OpenLineage.JobFacet
Enclosing class:
OpenLineage
public static final class OpenLineage.GcpComposerJobFacet extends Object implements OpenLineage.JobFacet
model class for GcpComposerJobFacet

  • 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

    • getEnvironmentName

      public String getEnvironmentName()
      Returns:
      Cloud Composer Environment name

    • getDagId

      public String getDagId()
      Returns:
      The id of the DAG

    • getOperator

      public String getOperator()
      Returns:
      Operator class name. Only present for tasks, not for DAGs. For example `PythonOperator`

    • getTaskId

      public String getTaskId()
      Returns:
      The id of the task. Only present for tasks, not for DAGs

    • getAirflowVersion

      public String getAirflowVersion()
      Returns:
      Version of Airflow, suffixed by `+composer`

    • getComposerVersion

      public String getComposerVersion()
      Returns:
      Version of the Cloud Composer environment

    • getAdditionalProperties

      public Map<String,Object> getAdditionalProperties()
      Specified by:
      getAdditionalProperties in interface OpenLineage.JobFacet
      Returns:
      additional properties