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

Class OpenLineageIcebergCommitReportOutputDataSetFacetMetrics

java.lang.Object
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageIcebergCommitReportOutputDataSetFacetMetrics
public class OpenLineageIcebergCommitReportOutputDataSetFacetMetrics extends Object
This class represents the commit metrics reported by Apache Iceberg for a write to a table. It is part of the OpenLineage spec.

  • Constructor Details

    • OpenLineageIcebergCommitReportOutputDataSetFacetMetrics

      public OpenLineageIcebergCommitReportOutputDataSetFacetMetrics()
      Default constructor

  • Method Details

    • getTotalDuration

      public Double getTotalDuration()
      Return the total duration of the commit in milliseconds.
      Returns:
      double

    • setTotalDuration

      public void setTotalDuration(Double totalDuration)
      Set up the total duration of the commit in milliseconds.
      Parameters:
      totalDuration - double

    • getAttempts

      public Double getAttempts()
      Return the number of commit attempts.
      Returns:
      double

    • setAttempts

      public void setAttempts(Double attempts)
      Set up the number of commit attempts.
      Parameters:
      attempts - double

    • getAddedDataFiles

      public Double getAddedDataFiles()
      Return the number of data files added.
      Returns:
      double

    • setAddedDataFiles

      public void setAddedDataFiles(Double addedDataFiles)
      Set up the number of data files added.
      Parameters:
      addedDataFiles - double

    • getRemovedDataFiles

      public Double getRemovedDataFiles()
      Return the number of data files removed.
      Returns:
      double

    • setRemovedDataFiles

      public void setRemovedDataFiles(Double removedDataFiles)
      Set up the number of data files removed.
      Parameters:
      removedDataFiles - double

    • getTotalDataFiles

      public Double getTotalDataFiles()
      Return the total number of data files after the commit.
      Returns:
      double

    • setTotalDataFiles

      public void setTotalDataFiles(Double totalDataFiles)
      Set up the total number of data files after the commit.
      Parameters:
      totalDataFiles - double

    • getAddedDeleteFiles

      public Double getAddedDeleteFiles()
      Return the number of delete files added.
      Returns:
      double

    • setAddedDeleteFiles

      public void setAddedDeleteFiles(Double addedDeleteFiles)
      Set up the number of delete files added.
      Parameters:
      addedDeleteFiles - double

    • getAddedEqualityDeleteFiles

      public Double getAddedEqualityDeleteFiles()
      Return the number of equality delete files added.
      Returns:
      double

    • setAddedEqualityDeleteFiles

      public void setAddedEqualityDeleteFiles(Double addedEqualityDeleteFiles)
      Set up the number of equality delete files added.
      Parameters:
      addedEqualityDeleteFiles - double

    • getAddedPositionalDeleteFiles

      public Double getAddedPositionalDeleteFiles()
      Return the number of positional delete files added.
      Returns:
      double

    • setAddedPositionalDeleteFiles

      public void setAddedPositionalDeleteFiles(Double addedPositionalDeleteFiles)
      Set up the number of positional delete files added.
      Parameters:
      addedPositionalDeleteFiles - double

    • getAddedDVs

      public Double getAddedDVs()
      Return the number of deletion vectors added.
      Returns:
      double

    • setAddedDVs

      public void setAddedDVs(Double addedDVs)
      Set up the number of deletion vectors added.
      Parameters:
      addedDVs - double

    • getRemovedDeleteFiles

      public Double getRemovedDeleteFiles()
      Return the number of delete files removed.
      Returns:
      double

    • setRemovedDeleteFiles

      public void setRemovedDeleteFiles(Double removedDeleteFiles)
      Set up the number of delete files removed.
      Parameters:
      removedDeleteFiles - double

    • getRemovedEqualityDeleteFiles

      public Double getRemovedEqualityDeleteFiles()
      Return the number of equality delete files removed.
      Returns:
      double

    • setRemovedEqualityDeleteFiles

      public void setRemovedEqualityDeleteFiles(Double removedEqualityDeleteFiles)
      Set up the number of equality delete files removed.
      Parameters:
      removedEqualityDeleteFiles - double

    • getRemovedPositionalDeleteFiles

      public Double getRemovedPositionalDeleteFiles()
      Return the number of positional delete files removed.
      Returns:
      double

    • setRemovedPositionalDeleteFiles

      public void setRemovedPositionalDeleteFiles(Double removedPositionalDeleteFiles)
      Set up the number of positional delete files removed.
      Parameters:
      removedPositionalDeleteFiles - double

    • getRemovedDVs

      public Double getRemovedDVs()
      Return the number of deletion vectors removed.
      Returns:
      double

    • setRemovedDVs

      public void setRemovedDVs(Double removedDVs)
      Set up the number of deletion vectors removed.
      Parameters:
      removedDVs - double

    • getTotalDeleteFiles

      public Double getTotalDeleteFiles()
      Return the total number of delete files after the commit.
      Returns:
      double

    • setTotalDeleteFiles

      public void setTotalDeleteFiles(Double totalDeleteFiles)
      Set up the total number of delete files after the commit.
      Parameters:
      totalDeleteFiles - double

    • getAddedRecords

      public Double getAddedRecords()
      Return the number of records added.
      Returns:
      double

    • setAddedRecords

      public void setAddedRecords(Double addedRecords)
      Set up the number of records added.
      Parameters:
      addedRecords - double

    • getRemovedRecords

      public Double getRemovedRecords()
      Return the number of records removed.
      Returns:
      double

    • setRemovedRecords

      public void setRemovedRecords(Double removedRecords)
      Set up the number of records removed.
      Parameters:
      removedRecords - double

    • getTotalRecords

      public Double getTotalRecords()
      Return the total number of records after the commit.
      Returns:
      double

    • setTotalRecords

      public void setTotalRecords(Double totalRecords)
      Set up the total number of records after the commit.
      Parameters:
      totalRecords - double

    • getAddedFilesSizeInBytes

      public Double getAddedFilesSizeInBytes()
      Return the size in bytes of the files added.
      Returns:
      double

    • setAddedFilesSizeInBytes

      public void setAddedFilesSizeInBytes(Double addedFilesSizeInBytes)
      Set up the size in bytes of the files added.
      Parameters:
      addedFilesSizeInBytes - double

    • getRemovedFilesSizeInBytes

      public Double getRemovedFilesSizeInBytes()
      Return the size in bytes of the files removed.
      Returns:
      double

    • setRemovedFilesSizeInBytes

      public void setRemovedFilesSizeInBytes(Double removedFilesSizeInBytes)
      Set up the size in bytes of the files removed.
      Parameters:
      removedFilesSizeInBytes - double

    • getTotalFilesSizeInBytes

      public Double getTotalFilesSizeInBytes()
      Return the total size in bytes of the files after the commit.
      Returns:
      double

    • setTotalFilesSizeInBytes

      public void setTotalFilesSizeInBytes(Double totalFilesSizeInBytes)
      Set up the total size in bytes of the files after the commit.
      Parameters:
      totalFilesSizeInBytes - double

    • getAddedPositionalDeletes

      public Double getAddedPositionalDeletes()
      Return the number of positional deletes added.
      Returns:
      double

    • setAddedPositionalDeletes

      public void setAddedPositionalDeletes(Double addedPositionalDeletes)
      Set up the number of positional deletes added.
      Parameters:
      addedPositionalDeletes - double

    • getRemovedPositionalDeletes

      public Double getRemovedPositionalDeletes()
      Return the number of positional deletes removed.
      Returns:
      double

    • setRemovedPositionalDeletes

      public void setRemovedPositionalDeletes(Double removedPositionalDeletes)
      Set up the number of positional deletes removed.
      Parameters:
      removedPositionalDeletes - double

    • getTotalPositionalDeletes

      public Double getTotalPositionalDeletes()
      Return the total number of positional deletes after the commit.
      Returns:
      double

    • setTotalPositionalDeletes

      public void setTotalPositionalDeletes(Double totalPositionalDeletes)
      Set up the total number of positional deletes after the commit.
      Parameters:
      totalPositionalDeletes - double

    • getAddedEqualityDeletes

      public Double getAddedEqualityDeletes()
      Return the number of equality deletes added.
      Returns:
      double

    • setAddedEqualityDeletes

      public void setAddedEqualityDeletes(Double addedEqualityDeletes)
      Set up the number of equality deletes added.
      Parameters:
      addedEqualityDeletes - double

    • getRemovedEqualityDeletes

      public Double getRemovedEqualityDeletes()
      Return the number of equality deletes removed.
      Returns:
      double

    • setRemovedEqualityDeletes

      public void setRemovedEqualityDeletes(Double removedEqualityDeletes)
      Set up the number of equality deletes removed.
      Parameters:
      removedEqualityDeletes - double

    • getTotalEqualityDeletes

      public Double getTotalEqualityDeletes()
      Return the total number of equality deletes after the commit.
      Returns:
      double

    • setTotalEqualityDeletes

      public void setTotalEqualityDeletes(Double totalEqualityDeletes)
      Set up the total number of equality deletes after the commit.
      Parameters:
      totalEqualityDeletes - double

    • 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