Class OpenLineage.JobTypeJobFacetBuilder

    • Constructor Detail

      • JobTypeJobFacetBuilder

        public JobTypeJobFacetBuilder()
    • Method Detail

      • processingType

        public OpenLineage.JobTypeJobFacetBuilder processingType​(java.lang.String processingType)
        Parameters:
        processingType - Job processing type like: BATCH or STREAMING
        Returns:
        this
      • integration

        public OpenLineage.JobTypeJobFacetBuilder integration​(java.lang.String integration)
        Parameters:
        integration - OpenLineage integration type of this job: for example SPARK|DBT|AIRFLOW|FLINK
        Returns:
        this
      • jobType

        public OpenLineage.JobTypeJobFacetBuilder jobType​(java.lang.String jobType)
        Parameters:
        jobType - Run type, for example: QUERY|COMMAND|DAG|TASK|JOB|MODEL. This is an integration-specific field.
        Returns:
        this
      • put

        public OpenLineage.JobTypeJobFacetBuilder put​(java.lang.String key,
                                                      java.lang.Object value)
        add additional properties
        Parameters:
        key - the additional property name
        value - the additional property value
        Returns:
        this