MCPcopy Create free account
hub / github.com/apache/arrow / poll

Method poll

cpp/src/arrow/ipc/reader.cc:1628–1638  ·  view source on GitHub ↗

\brief Capture a copy of the current counters

Source from the content-addressed store, hash-verified

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 {

Callers 5

write_stdinMethod · 0.80
wait_until_readyMethod · 0.80
gcs_serverFunction · 0.80
azure_serverFunction · 0.80
statsMethod · 0.80

Calls 1

loadMethod · 0.45

Tested by 4

write_stdinMethod · 0.64
wait_until_readyMethod · 0.64
gcs_serverFunction · 0.64
azure_serverFunction · 0.64