\brief Capture a copy of the current counters
| 1626 | |
| 1627 | /// \brief Capture a copy of the current counters |
| 1628 | ReadStats poll() const { |
| 1629 | ReadStats stats; |
| 1630 | stats.num_messages = num_messages.load(std::memory_order_relaxed); |
| 1631 | stats.num_record_batches = num_record_batches.load(std::memory_order_relaxed); |
| 1632 | stats.num_dictionary_batches = |
| 1633 | num_dictionary_batches.load(std::memory_order_relaxed); |
| 1634 | stats.num_dictionary_deltas = num_dictionary_deltas.load(std::memory_order_relaxed); |
| 1635 | stats.num_replaced_dictionaries = |
| 1636 | num_replaced_dictionaries.load(std::memory_order_relaxed); |
| 1637 | return stats; |
| 1638 | } |
| 1639 | }; |
| 1640 | |
| 1641 | Result<FileBlock> GetRecordBatchBlock(int i) const { |