File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1919 */
2020#include " iceberg/transaction.h"
2121
22- #include < format>
2322#include < chrono>
23+ #include < format>
2424#include < memory>
2525#include < optional>
2626
@@ -468,10 +468,10 @@ Result<std::shared_ptr<SnapshotManager>> Transaction::NewSnapshotManager() {
468468}
469469
470470void Transaction::ReportCommitMetrics (DurationMs duration) const {
471- const auto & reporter = table_ ->reporter ();
471+ const auto & reporter = ctx_-> table ->reporter ();
472472 if (!reporter) return ;
473473
474- auto snapshot_result = table_ ->current_snapshot ();
474+ auto snapshot_result = ctx_-> table ->current_snapshot ();
475475 if (!snapshot_result.has_value () || !snapshot_result.value ()) return ;
476476
477477 const auto & snapshot = snapshot_result.value ();
@@ -487,7 +487,7 @@ void Transaction::ReportCommitMetrics(DurationMs duration) const {
487487 };
488488
489489 CommitReport report;
490- report.table_name = table_ ->name ().ToString ();
490+ report.table_name = ctx_-> table ->name ().ToString ();
491491 report.snapshot_id = snapshot->snapshot_id ;
492492 report.sequence_number = snapshot->sequence_number ;
493493 report.total_duration = duration;
You can’t perform that action at this time.
0 commit comments