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

Method poll

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

\brief Capture a copy of the current counters

Source from the content-addressed store, hash-verified

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 {

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