Method recordAcknowledge

bolt/exec/OutputBuffer.cpp:88–101

}

void DestinationBuffer::Stats::recordAcknowledge(const SerializedPage& data) {
  const auto numRows = data.numRows();
  BOLT_CHECK(numRows.has_value(), "SerializedPage's numRows must be valid");
  const int64_t size = data.size();
  bytesBuffered -= size;
  BOLT_DCHECK_GE(bytesBuffered, 0, "bytesBuffered must be non-negative");
  rowsBuffered -= numRows.value();
  BOLT_DCHECK_GE(rowsBuffered, 0, "rowsBuffered must be non-negative");
  --pagesBuffered;
  BOLT_DCHECK_GE(pagesBuffered, 0, "pagesBuffered must be non-negative");
  bytesSent += size;
  rowsSent += numRows.value();
  ++pagesSent;
}

void DestinationBuffer::Stats::recordDelete(const SerializedPage& data) {
  recordAcknowledge(data);