| 528 | } |
| 529 | |
| 530 | void DmlExecState::UpdatePartition(const string& partition_name, |
| 531 | int64_t num_rows_delta, const DmlStatsPB* insert_stats, bool is_delete) { |
| 532 | lock_guard<mutex> l(lock_); |
| 533 | PartitionStatusMap::iterator entry = per_partition_status_.find(partition_name); |
| 534 | DCHECK(entry != per_partition_status_.end()); |
| 535 | if (is_delete) { |
| 536 | entry->second.set_num_deleted_rows( |
| 537 | entry->second.num_deleted_rows() + num_rows_delta); |
| 538 | } else { |
| 539 | entry->second.set_num_modified_rows( |
| 540 | entry->second.num_modified_rows() + num_rows_delta); |
| 541 | } |
| 542 | if (insert_stats == nullptr) return; |
| 543 | MergeDmlStats(*insert_stats, entry->second.mutable_stats()); |
| 544 | } |
| 545 | |
| 546 | namespace { |
| 547 | flatbuffers::Offset<org::apache::impala::fb::FbIcebergColumnStats> |
no test coverage detected