Method CalculateRowBatchCapacity

be/src/runtime/krpc-data-stream-sender.cc:392–396

}

int KrpcDataStreamSender::Channel::CalculateRowBatchCapacity() const {
  // TODO: take into account of var-len data at runtime.
  return
      max(1, parent_->per_channel_buffer_size_ / max(row_desc_->GetRowSize(), 1));
}

void KrpcDataStreamSender::Channel::MarkDone(const Status& status) {
  if (UNLIKELY(!status.ok())) {