| 165 | } |
| 166 | |
| 167 | Status ExchangeNode::FillInputRowBatch(RuntimeState* state) { |
| 168 | DCHECK(!is_merging_); |
| 169 | Status ret_status; |
| 170 | { |
| 171 | SCOPED_TIMER(state->total_network_receive_timer()); |
| 172 | ret_status = stream_recvr_->GetBatch(&input_batch_); |
| 173 | } |
| 174 | VLOG_FILE << "exch: has batch=" << (input_batch_ == NULL ? "false" : "true") |
| 175 | << " #rows=" << (input_batch_ != NULL ? input_batch_->num_rows() : 0) |
| 176 | << " is_cancelled=" << (ret_status.IsCancelled() ? "true" : "false") |
| 177 | << " instance_id=" << PrintId(state->fragment_instance_id()); |
| 178 | return ret_status; |
| 179 | } |
| 180 | |
| 181 | void ExchangeNode::ReleaseRecvrResources(RowBatch* output_batch) { |
| 182 | stream_recvr_->TransferAllResources(output_batch); |
nothing calls this directly
no test coverage detected