| 257 | BloomFilterBuilder* bloom_filter_builder_; |
| 258 | |
| 259 | void CheckRowsWritten() const { |
| 260 | // verify when only one column is written at a time |
| 261 | if (!buffered_row_group_ && column_writers_.size() > 0 && column_writers_[0]) { |
| 262 | int64_t current_col_rows = column_writers_[0]->rows_written(); |
| 263 | if (num_rows_ == 0) { |
| 264 | num_rows_ = current_col_rows; |
| 265 | } else if (num_rows_ != current_col_rows) { |
| 266 | ThrowRowsMisMatchError(next_column_index_, current_col_rows, num_rows_); |
| 267 | } |
| 268 | } else if (buffered_row_group_ && |
| 269 | column_writers_.size() > 0) { // when buffered_row_group = true |
| 270 | DCHECK(column_writers_[0] != nullptr); |
| 271 | int64_t current_col_rows = column_writers_[0]->rows_written(); |
| 272 | for (int i = 1; i < static_cast<int>(column_writers_.size()); i++) { |
| 273 | DCHECK(column_writers_[i] != nullptr); |
| 274 | int64_t current_col_rows_i = column_writers_[i]->rows_written(); |
| 275 | if (current_col_rows != current_col_rows_i) { |
| 276 | ThrowRowsMisMatchError(i, current_col_rows_i, current_col_rows); |
| 277 | } |
| 278 | } |
| 279 | num_rows_ = current_col_rows; |
| 280 | } |
| 281 | } |
| 282 | |
| 283 | void InitColumns() { |
| 284 | for (int i = 0; i < RowGroupSerializer::num_columns(); i++) { |
nothing calls this directly
no test coverage detected