Method SerializeAndSendBatch

be/src/runtime/krpc-data-stream-sender.cc:619–625

}

Status KrpcDataStreamSender::Channel::SerializeAndSendBatch(RowBatch* batch) {
  unique_ptr<OutboundRowBatch>* serialization_batch = GetSerializationBatch();
  RETURN_IF_ERROR(parent_->SerializeBatch(batch, serialization_batch->get(), !is_local_));
  // Swap serialization_batch with outbound_batch_ once the old RPC is finished.
  RETURN_IF_ERROR(TransmitData(serialization_batch, true /*swap_batch*/));
  return Status::OK();
}

unique_ptr<OutboundRowBatch>* KrpcDataStreamSender::Channel::GetSerializationBatch() {
  unique_ptr<OutboundRowBatch>* serialization_batch = &parent_->serialization_batch_;