MCPcopy Create free account
hub / github.com/bytedance/bolt / recordEnqueue

Method recordEnqueue

bolt/exec/OutputBuffer.cpp:80–86  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

78}
79
80void DestinationBuffer::Stats::recordEnqueue(const SerializedPage& data) {
81 const auto numRows = data.numRows();
82 BOLT_CHECK(numRows.has_value(), "SerializedPage's numRows must be valid");
83 bytesBuffered += data.size();
84 rowsBuffered += numRows.value();
85 ++pagesBuffered;
86}
87
88void DestinationBuffer::Stats::recordAcknowledge(const SerializedPage& data) {
89 const auto numRows = data.numRows();

Callers 1

enqueueMethod · 0.80

Calls 4

has_valueMethod · 0.80
numRowsMethod · 0.45
sizeMethod · 0.45
valueMethod · 0.45

Tested by

no test coverage detected