Interface ModelCommitMetricsReport

All Superinterfaces:
org.apache.polaris.persistence.relational.jdbc.models.Converter<ModelCommitMetricsReport>

@PolarisImmutable public interface ModelCommitMetricsReport extends org.apache.polaris.persistence.relational.jdbc.models.Converter<ModelCommitMetricsReport>
Model class for commit_metrics_report table - stores commit metrics as first-class entities.
  • Field Details

  • Method Details

    • getReportId

      String getReportId()
    • getRealmId

      String getRealmId()
    • getCatalogId

      long getCatalogId()
    • getTableId

      long getTableId()
    • getTimestampMs

      long getTimestampMs()
    • getPrincipalName

      @Nullable String getPrincipalName()
    • getRequestId

      @Nullable String getRequestId()
    • getOtelTraceId

      @Nullable String getOtelTraceId()
    • getOtelSpanId

      @Nullable String getOtelSpanId()
    • getReportTraceId

      @Nullable String getReportTraceId()
    • getSnapshotId

      long getSnapshotId()
    • getSequenceNumber

      @Nullable Long getSequenceNumber()
    • getOperation

      String getOperation()
    • getAddedDataFiles

      long getAddedDataFiles()
    • getRemovedDataFiles

      long getRemovedDataFiles()
    • getTotalDataFiles

      long getTotalDataFiles()
    • getAddedDeleteFiles

      long getAddedDeleteFiles()
    • getRemovedDeleteFiles

      long getRemovedDeleteFiles()
    • getTotalDeleteFiles

      long getTotalDeleteFiles()
    • getAddedEqualityDeleteFiles

      long getAddedEqualityDeleteFiles()
    • getRemovedEqualityDeleteFiles

      long getRemovedEqualityDeleteFiles()
    • getAddedPositionalDeleteFiles

      long getAddedPositionalDeleteFiles()
    • getRemovedPositionalDeleteFiles

      long getRemovedPositionalDeleteFiles()
    • getAddedRecords

      long getAddedRecords()
    • getRemovedRecords

      long getRemovedRecords()
    • getTotalRecords

      long getTotalRecords()
    • getAddedFileSizeBytes

      long getAddedFileSizeBytes()
    • getRemovedFileSizeBytes

      long getRemovedFileSizeBytes()
    • getTotalFileSizeBytes

      long getTotalFileSizeBytes()
    • getTotalDurationMs

      long getTotalDurationMs()
    • getAttempts

      int getAttempts()
    • getMetadata

      @Nullable String getMetadata()
    • fromResultSet

      default ModelCommitMetricsReport fromResultSet(ResultSet rs) throws SQLException
      Specified by:
      fromResultSet in interface org.apache.polaris.persistence.relational.jdbc.models.Converter<ModelCommitMetricsReport>
      Throws:
      SQLException
    • toMap

      default Map<String,Object> toMap(org.apache.polaris.persistence.relational.jdbc.DatabaseType databaseType)
      Specified by:
      toMap in interface org.apache.polaris.persistence.relational.jdbc.models.Converter<ModelCommitMetricsReport>
    • fromRecord

      static ModelCommitMetricsReport fromRecord(org.apache.polaris.core.persistence.metrics.CommitMetricsRecord record, String realmId)
      Converts a CommitMetricsRecord (SPI) to ModelCommitMetricsReport (JDBC).

      Request context fields (principalName, requestId, otelTraceId, otelSpanId) are read directly from the record, which should have been populated by the service layer.

      Parameters:
      record - the SPI record containing all metrics and request context
      realmId - the realm ID for multi-tenancy
      Returns:
      the JDBC model