Class OpenLineageSQLJobFacet


public class OpenLineageSQLJobFacet extends OpenLineageJobFacet
This class represents the sql job facet. It captures the SQL query executed by the job. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-1-0/SQLJobFacet.json#/$defs/SQLJobFacet.
  • Constructor Details

    • OpenLineageSQLJobFacet

      public OpenLineageSQLJobFacet()
      Default constructor
  • Method Details

    • getQuery

      public String getQuery()
      Return the SQL query.
      Returns:
      string
    • setQuery

      public void setQuery(String query)
      Set up the SQL query.
      Parameters:
      query - string
    • getDialect

      public String getDialect()
      Return the SQL dialect of the query.
      Returns:
      string
    • setDialect

      public void setDialect(String dialect)
      Set up the SQL dialect of the query.
      Parameters:
      dialect - string
    • toString

      public String toString()
      Standard toString method.
      Overrides:
      toString in class OpenLineageJobFacet
      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 OpenLineageJobFacet
      Parameters:
      objectToCompare - supplied object
      Returns:
      boolean result of comparison
    • hashCode

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