\brief Capture a copy of the current counters
| 1616 | |
| 1617 | /// \brief Capture a copy of the current counters |
| 1618 | ReadStats poll() const { |
| 1619 | ReadStats stats; |
| 1620 | stats.num_messages = num_messages.load(std::memory_order_relaxed); |
| 1621 | stats.num_record_batches = num_record_batches.load(std::memory_order_relaxed); |
| 1622 | stats.num_dictionary_batches = |
| 1623 | num_dictionary_batches.load(std::memory_order_relaxed); |
| 1624 | stats.num_dictionary_deltas = num_dictionary_deltas.load(std::memory_order_relaxed); |
| 1625 | stats.num_replaced_dictionaries = |
| 1626 | num_replaced_dictionaries.load(std::memory_order_relaxed); |
| 1627 | return stats; |
| 1628 | } |
| 1629 | }; |
| 1630 | |
| 1631 | Result<FileBlock> GetRecordBatchBlock(int i) const { |