| 1320 | } |
| 1321 | |
| 1322 | Status KrpcDataStreamSender::SerializeBatch( |
| 1323 | RowBatch* src, OutboundRowBatch* dest, bool compress, int num_receivers) { |
| 1324 | VLOG_ROW << "serializing " << src->num_rows() << " rows"; |
| 1325 | { |
| 1326 | SCOPED_TIMER(serialize_batch_timer_); |
| 1327 | RETURN_IF_ERROR( |
| 1328 | src->Serialize(dest, compress ? compression_scratch_.get() : nullptr)); |
| 1329 | int64_t uncompressed_bytes = RowBatch::GetDeserializedSize(*dest); |
| 1330 | COUNTER_ADD(uncompressed_bytes_counter_, uncompressed_bytes * num_receivers); |
| 1331 | } |
| 1332 | return Status::OK(); |
| 1333 | } |
| 1334 | |
| 1335 | Status KrpcDataStreamSender::PrepareBatchForSend( |
| 1336 | OutboundRowBatch* batch, bool compress) { |
no test coverage detected