Helper function to generate the unique id based on fragment instance id and node id.
| 251 | |
| 252 | // Helper function to generate the unique id based on fragment instance id and node id. |
| 253 | static string GenerateFragmentNodeId( |
| 254 | const RuntimeState* state, const TupleCacheNode* node) { |
| 255 | DCHECK(state != nullptr); |
| 256 | DCHECK(node != nullptr); |
| 257 | return Substitute("$0_$1", PrintId(state->fragment_instance_id()), node->id()); |
| 258 | } |
| 259 | |
| 260 | Status TupleCacheNode::GetNext( |
| 261 | RuntimeState* state, RowBatch* output_row_batch, bool* eos) { |
no test coverage detected