Package org.odpi.openmetadata.frameworks.integration.openlineage

Class OpenLineageRunFacets

java.lang.Object
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageRunFacets
public class OpenLineageRunFacets extends Object
This class represents the map of run facets for a run. The standard facets from the OpenLineage spec, and the custom facets registered in the OpenLineage registry, are held in named properties. Any other facets (custom facets, or standard facets not yet modelled) are held in the additionalProperties map, keyed by their facet name, so that nothing is lost on a round trip through these beans. The map key of each facet in the JSON is the facet's key from the OpenLineage spec.

  • Constructor Details

    • OpenLineageRunFacets

      public OpenLineageRunFacets()
      Default constructor

  • Method Details

    • getParent

      public OpenLineageParentRunFacet getParent()
      Return the parent facet.
      Returns:
      facet bean

    • setParent

      public void setParent(OpenLineageParentRunFacet parent)
      Set up the parent facet.
      Parameters:
      parent - facet bean

    • getNominalTime

      public OpenLineageNominalTimeRunFacet getNominalTime()
      Return the nominalTime facet.
      Returns:
      facet bean

    • setNominalTime

      public void setNominalTime(OpenLineageNominalTimeRunFacet nominalTime)
      Set up the nominalTime facet.
      Parameters:
      nominalTime - facet bean

    • getEnvironmentVariables

      public OpenLineageEnvironmentVariablesRunFacet getEnvironmentVariables()
      Return the environmentVariables facet.
      Returns:
      facet bean

    • setEnvironmentVariables

      public void setEnvironmentVariables(OpenLineageEnvironmentVariablesRunFacet environmentVariables)
      Set up the environmentVariables facet.
      Parameters:
      environmentVariables - facet bean

    • getErrorMessage

      public OpenLineageErrorMessageRunFacet getErrorMessage()
      Return the errorMessage facet.
      Returns:
      facet bean

    • setErrorMessage

      public void setErrorMessage(OpenLineageErrorMessageRunFacet errorMessage)
      Set up the errorMessage facet.
      Parameters:
      errorMessage - facet bean

    • getExecutionParameters

      public OpenLineageExecutionParametersRunFacet getExecutionParameters()
      Return the executionParameters facet.
      Returns:
      facet bean

    • setExecutionParameters

      public void setExecutionParameters(OpenLineageExecutionParametersRunFacet executionParameters)
      Set up the executionParameters facet.
      Parameters:
      executionParameters - facet bean

    • getExternalQuery

      public OpenLineageExternalQueryRunFacet getExternalQuery()
      Return the externalQuery facet.
      Returns:
      facet bean

    • setExternalQuery

      public void setExternalQuery(OpenLineageExternalQueryRunFacet externalQuery)
      Set up the externalQuery facet.
      Parameters:
      externalQuery - facet bean

    • getExtractionError

      public OpenLineageExtractionErrorRunFacet getExtractionError()
      Return the extractionError facet.
      Returns:
      facet bean

    • setExtractionError

      public void setExtractionError(OpenLineageExtractionErrorRunFacet extractionError)
      Set up the extractionError facet.
      Parameters:
      extractionError - facet bean

    • getJobDependencies

      public OpenLineageJobDependenciesRunFacet getJobDependencies()
      Return the jobDependencies facet.
      Returns:
      facet bean

    • setJobDependencies

      public void setJobDependencies(OpenLineageJobDependenciesRunFacet jobDependencies)
      Set up the jobDependencies facet.
      Parameters:
      jobDependencies - facet bean

    • getProcessingEngine

      public OpenLineageProcessingEngineRunFacet getProcessingEngine()
      Return the processing_engine facet.
      Returns:
      facet bean

    • setProcessingEngine

      public void setProcessingEngine(OpenLineageProcessingEngineRunFacet processingEngine)
      Set up the processing_engine facet.
      Parameters:
      processingEngine - facet bean

    • getTags

      public OpenLineageTagsRunFacet getTags()
      Return the tags facet.
      Returns:
      facet bean

    • setTags

      public void setTags(OpenLineageTagsRunFacet tags)
      Set up the tags facet.
      Parameters:
      tags - facet bean

    • getTest

      public OpenLineageTestRunFacet getTest()
      Return the test facet.
      Returns:
      facet bean

    • setTest

      public void setTest(OpenLineageTestRunFacet test)
      Set up the test facet.
      Parameters:
      test - facet bean

    • getGcpComposerRun

      public OpenLineageGcpComposerRunFacet getGcpComposerRun()
      Return the gcp_composer_run facet.
      Returns:
      facet bean

    • setGcpComposerRun

      public void setGcpComposerRun(OpenLineageGcpComposerRunFacet gcpComposerRun)
      Set up the gcp_composer_run facet.
      Parameters:
      gcpComposerRun - facet bean

    • getGcpDataproc

      public OpenLineageGcpDataprocRunFacet getGcpDataproc()
      Return the gcp_dataproc facet.
      Returns:
      facet bean

    • setGcpDataproc

      public void setGcpDataproc(OpenLineageGcpDataprocRunFacet gcpDataproc)
      Set up the gcp_dataproc facet.
      Parameters:
      gcpDataproc - facet bean

    • getAdditionalProperties

      public Map<String,OpenLineageRunFacet> getAdditionalProperties()
      Return any additional facets that are not modelled as named properties. They are serialized as top-level facet entries alongside the named facets.
      Returns:
      map of facet name to facet

    • setAdditionalProperties

      public void setAdditionalProperties(Map<String,OpenLineageRunFacet> additionalProperties)
      Set up any additional facets that are not modelled as named properties.
      Parameters:
      additionalProperties - map of facet name to facet

    • setAdditionalProperty

      public void setAdditionalProperty(String facetName, OpenLineageRunFacet facet)
      Add a facet that is not modelled as a named property. Jackson calls this for each unrecognized facet found in the JSON.
      Parameters:
      facetName - name (key) of the facet
      facet - facet bean

    • toString

      public String toString()
      Standard toString method.
      Overrides:
      toString in class Object
      Returns:
      print out of variables in a JSON-style

    • equals

      public boolean equals(Object objectToCompare)
      Compare the values of the supplied object with those stored in the current object.
      Overrides:
      equals in class Object
      Parameters:
      objectToCompare - supplied object
      Returns:
      boolean result of comparison

    • hashCode

      public int hashCode()
      Return hash code based on properties.
      Overrides:
      hashCode in class Object
      Returns:
      int