| 146 | } |
| 147 | |
| 148 | uint64_t DmlExecState::GetKuduLatestObservedTimestamp() { |
| 149 | lock_guard<mutex> l(lock_); |
| 150 | uint64_t max_ts = 0; |
| 151 | for (const PartitionStatusMap::value_type& p : per_partition_status_) { |
| 152 | max_ts = max<uint64_t>(max_ts, p.second.kudu_latest_observed_ts()); |
| 153 | } |
| 154 | return max_ts; |
| 155 | } |
| 156 | |
| 157 | int64_t DmlExecState::GetNumModifiedRows() { |
| 158 | lock_guard<mutex> l(lock_); |