| 376 | } |
| 377 | |
| 378 | bool ScannerContext::cancelled() const { |
| 379 | if (state_->is_cancelled()) return true; |
| 380 | if (!scan_node_->HasRowBatchQueue()) return false; |
| 381 | return static_cast<HdfsScanNode*>(scan_node_)->done(); |
| 382 | } |
| 383 | |
| 384 | bool ScannerContext::Stream::ValidateBufferPointers() const { |
| 385 | // If there are bytes left in the boundary buffer, the output buffer pointers must point |
no test coverage detected