Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: apache/amoro
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: c6c8d2552ddb397e92f1ac2f9a048b3a4b2502e2
Choose a base ref
..
head repository: apache/amoro
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: df85917ec2d673e240d1076058fc3dbcbf5724d6
Choose a head ref
Showing with 20 additions and 20 deletions.
  1. +20 −20 amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/table/TableSummaryMetrics.java
Original file line number Diff line number Diff line change
@@ -204,33 +204,33 @@ public void unregister() {
globalRegistry = null;
}

public void refresh(OptimizingEvaluator.PendingInput pendingInput) {
if (pendingInput == null) {
public void refresh(OptimizingEvaluator.PendingInput tableSummary) {
if (tableSummary == null) {
return;
}
totalFiles =
pendingInput.getDataFileCount()
+ pendingInput.getEqualityDeleteFileCount()
+ pendingInput.getPositionalDeleteFileCount();
dataFiles = pendingInput.getDataFileCount();
positionDeleteFiles = pendingInput.getPositionalDeleteFileCount();
equalityDeleteFiles = pendingInput.getEqualityDeleteFileCount();
tableSummary.getDataFileCount()
+ tableSummary.getEqualityDeleteFileCount()
+ tableSummary.getPositionalDeleteFileCount();
dataFiles = tableSummary.getDataFileCount();
positionDeleteFiles = tableSummary.getPositionalDeleteFileCount();
equalityDeleteFiles = tableSummary.getEqualityDeleteFileCount();

totalFilesSize =
pendingInput.getDataFileSize()
+ pendingInput.getEqualityDeleteBytes()
+ pendingInput.getPositionalDeleteBytes();
positionDeleteFilesSize = pendingInput.getPositionalDeleteBytes();
dataFilesSize = pendingInput.getDataFileSize();
equalityDeleteFilesSize = pendingInput.getEqualityDeleteBytes();
tableSummary.getDataFileSize()
+ tableSummary.getEqualityDeleteBytes()
+ tableSummary.getPositionalDeleteBytes();
positionDeleteFilesSize = tableSummary.getPositionalDeleteBytes();
dataFilesSize = tableSummary.getDataFileSize();
equalityDeleteFilesSize = tableSummary.getEqualityDeleteBytes();

totalRecords =
pendingInput.getDataFileRecords()
+ pendingInput.getEqualityDeleteFileRecords()
+ pendingInput.getPositionalDeleteFileRecords();
positionDeleteFilesRecords = pendingInput.getPositionalDeleteFileRecords();
dataFilesRecords = pendingInput.getDataFileRecords();
equalityDeleteFilesRecords = pendingInput.getEqualityDeleteFileRecords();
tableSummary.getDataFileRecords()
+ tableSummary.getEqualityDeleteFileRecords()
+ tableSummary.getPositionalDeleteFileRecords();
positionDeleteFilesRecords = tableSummary.getPositionalDeleteFileRecords();
dataFilesRecords = tableSummary.getDataFileRecords();
equalityDeleteFilesRecords = tableSummary.getEqualityDeleteFileRecords();
}

public void refreshSnapshots(MixedTable table) {