| 474 | } |
| 475 | |
| 476 | void JoinReceivers() { |
| 477 | VLOG_QUERY << "join receiver\n"; |
| 478 | for (int i = 0; i < receiver_info_.size(); ++i) { |
| 479 | if (receiver_info_[i]->thread_handle != nullptr) { |
| 480 | receiver_info_[i]->thread_handle->join(); |
| 481 | } |
| 482 | receiver_info_[i]->stream_recvr->Close(); |
| 483 | } |
| 484 | } |
| 485 | |
| 486 | // Deplete stream and print batches |
| 487 | void ReadStream(ReceiverInfo* info) { |