| 390 | } |
| 391 | |
| 392 | void StreamReader::EndRow() { |
| 393 | if (!file_reader_) { |
| 394 | throw ParquetException("StreamReader not initialized"); |
| 395 | } |
| 396 | if (static_cast<std::size_t>(column_index_) < nodes_.size()) { |
| 397 | throw ParquetException("Cannot end row with " + std::to_string(column_index_) + |
| 398 | " of " + std::to_string(nodes_.size()) + " columns read"); |
| 399 | } |
| 400 | column_index_ = 0; |
| 401 | ++current_row_; |
| 402 | |
| 403 | if (!column_readers_[0]->HasNext()) { |
| 404 | NextRowGroup(); |
| 405 | } |
| 406 | } |
| 407 | |
| 408 | void StreamReader::NextRowGroup() { |
| 409 | // Find next none-empty row group |
no test coverage detected