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

Class OpenLineageIcebergScanReportInputDataSetFacet

java.lang.Object
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageFacet
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageInputDataSetInputFacet
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageIcebergScanReportInputDataSetFacet
public class OpenLineageIcebergScanReportInputDataSetFacet extends OpenLineageInputDataSetInputFacet
This class represents the icebergScanReport input dataset facet registered by Apache Iceberg. It reports the snapshot, filter, projection and scan metrics of a read of an Iceberg table. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-0-1/IcebergScanReportInputDatasetFacet.json#/$defs/IcebergScanReportInputDatasetFacet.

  • Constructor Details

    • OpenLineageIcebergScanReportInputDataSetFacet

      public OpenLineageIcebergScanReportInputDataSetFacet()
      Default constructor

  • Method Details

    • getSnapshotId

      public Long getSnapshotId()
      Return the snapshot ID of the Iceberg table.
      Returns:
      long

    • setSnapshotId

      public void setSnapshotId(Long snapshotId)
      Set up the snapshot ID of the Iceberg table.
      Parameters:
      snapshotId - long

    • getFilterDescription

      public String getFilterDescription()
      Return the filter used to scan the Iceberg table.
      Returns:
      string

    • setFilterDescription

      public void setFilterDescription(String filterDescription)
      Set up the filter used to scan the Iceberg table.
      Parameters:
      filterDescription - string

    • getSchemaId

      public Long getSchemaId()
      Return the schema ID of the Iceberg table.
      Returns:
      long

    • setSchemaId

      public void setSchemaId(Long schemaId)
      Set up the schema ID of the Iceberg table.
      Parameters:
      schemaId - long

    • getProjectedFieldNames

      public List<String> getProjectedFieldNames()
      Return the names of the fields projected from the Iceberg table.
      Returns:
      list

    • setProjectedFieldNames

      public void setProjectedFieldNames(List<String> projectedFieldNames)
      Set up the names of the fields projected from the Iceberg table.
      Parameters:
      projectedFieldNames - list

    • getScanMetrics

      public OpenLineageIcebergScanReportInputDataSetFacetMetrics getScanMetrics()
      Return the scan metrics.
      Returns:
      bean

    • setScanMetrics

      public void setScanMetrics(OpenLineageIcebergScanReportInputDataSetFacetMetrics scanMetrics)
      Set up the scan metrics.
      Parameters:
      scanMetrics - bean

    • getMetadata

      public Map<String,Object> getMetadata()
      Return the additional metadata reported with the scan.
      Returns:
      map

    • setMetadata

      public void setMetadata(Map<String,Object> metadata)
      Set up the additional metadata reported with the scan.
      Parameters:
      metadata - map

    • toString

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

    • hashCode

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