| 80 | } |
| 81 | |
| 82 | void OutboundRowBatch::SetHeader(int num_rows, int num_tuples_per_row, |
| 83 | int64_t uncompressed_size, bool is_compressed) { |
| 84 | header_.Clear(); |
| 85 | header_.set_num_rows(num_rows); |
| 86 | header_.set_num_tuples_per_row(num_tuples_per_row); |
| 87 | header_.set_uncompressed_size(uncompressed_size); |
| 88 | header_.set_compression_type( |
| 89 | is_compressed ? CompressionTypePB::LZ4 : CompressionTypePB::NONE); |
| 90 | } |
| 91 | |
| 92 | void OutboundRowBatch::Reset() { |
| 93 | header_.Clear(); |
nothing calls this directly
no test coverage detected