| 128 | } |
| 129 | |
| 130 | ColumnWriter* NextColumn() override { |
| 131 | if (buffered_row_group_) { |
| 132 | throw ParquetException( |
| 133 | "NextColumn() is not supported when a RowGroup is written by size"); |
| 134 | } |
| 135 | |
| 136 | if (column_writers_[0]) { |
| 137 | CheckRowsWritten(); |
| 138 | } |
| 139 | |
| 140 | // Throws an error if more columns are being written |
| 141 | auto col_meta = metadata_->NextColumnChunk(); |
| 142 | |
| 143 | if (column_writers_[0]) { |
| 144 | total_bytes_written_ += column_writers_[0]->Close(); |
| 145 | total_compressed_bytes_written_ += |
| 146 | column_writers_[0]->total_compressed_bytes_written(); |
| 147 | } |
| 148 | |
| 149 | const int32_t column_ordinal = next_column_index_++; |
| 150 | column_writers_[0] = CreateColumnWriterForColumn(col_meta, column_ordinal); |
| 151 | return column_writers_[0].get(); |
| 152 | } |
| 153 | |
| 154 | ColumnWriter* column(int i) override { |
| 155 | if (!buffered_row_group_) { |
nothing calls this directly
no test coverage detected