| 1241 | } |
| 1242 | |
| 1243 | Status WriteTable(const Table& table, int64_t max_chunksize) override { |
| 1244 | if (is_file_format_ && options_.unify_dictionaries) { |
| 1245 | ARROW_ASSIGN_OR_RAISE(auto unified_table, |
| 1246 | DictionaryUnifier::UnifyTable(table, options_.memory_pool)); |
| 1247 | return RecordBatchWriter::WriteTable(*unified_table, max_chunksize); |
| 1248 | } else { |
| 1249 | return RecordBatchWriter::WriteTable(table, max_chunksize); |
| 1250 | } |
| 1251 | } |
| 1252 | |
| 1253 | Status Close() override { |
| 1254 | RETURN_NOT_OK(CheckStarted()); |
no outgoing calls