Class OpenLineage.JobTypeJobFacet

    • Method Detail

      • get_producer

        public java.net.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 java.net.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 java.lang.Boolean get_deleted()
        Specified by:
        get_deleted in interface OpenLineage.JobFacet
        Returns:
        set to true to delete a facet
      • getProcessingType

        public java.lang.String getProcessingType()
        Returns:
        Job processing type like: BATCH or STREAMING
      • getIntegration

        public java.lang.String getIntegration()
        Returns:
        OpenLineage integration type of this job: for example SPARK|DBT|AIRFLOW|FLINK
      • getJobType

        public java.lang.String getJobType()
        Returns:
        Run type, for example: QUERY|COMMAND|DAG|TASK|JOB|MODEL. This is an integration-specific field.
      • getAdditionalProperties

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