| 429 | } |
| 430 | |
| 431 | void GetNextBatch(RowBatch* batch, int* next_val) { |
| 432 | for (int i = 0; i < BATCH_CAPACITY; ++i) { |
| 433 | TupleRow* row = batch->GetRow(i); |
| 434 | int64_t* val = reinterpret_cast<int64_t*>(row->GetTuple(0)->GetSlot(0)); |
| 435 | *val = (*next_val)++; |
| 436 | } |
| 437 | } |
| 438 | |
| 439 | // Start receiver expecting the given number of senders. |
| 440 | void StartReceiver(TPartitionType::type stream_type, int num_senders, int receiver_num, |