| 375 | } |
| 376 | |
| 377 | string BlockingJoinNode::GetLeftChildRowString(TupleRow* row) { |
| 378 | stringstream out; |
| 379 | out << "["; |
| 380 | int num_probe_tuple_rows = child(0)->row_desc()->tuple_descriptors().size(); |
| 381 | for (int i = 0; i < row_desc()->tuple_descriptors().size(); ++i) { |
| 382 | if (i != 0) out << " "; |
| 383 | if (i >= num_probe_tuple_rows) { |
| 384 | // Build row is not yet populated, print NULL |
| 385 | out << PrintTuple(NULL, *row_desc()->tuple_descriptors()[i]); |
| 386 | } else { |
| 387 | out << PrintTuple(row->GetTuple(i), *row_desc()->tuple_descriptors()[i]); |
| 388 | } |
| 389 | } |
| 390 | out << "]"; |
| 391 | return out.str(); |
| 392 | } |
| 393 | |
| 394 | int64_t BlockingJoinNode::LocalTimeCounterFn(const RuntimeProfile::Counter* total_time, |
| 395 | const RuntimeProfile::Counter* left_child_time, |
nothing calls this directly
no test coverage detected