| 1234 | } |
| 1235 | |
| 1236 | Status WriteTable(const Table& table, int64_t max_chunksize) override { |
| 1237 | if (is_file_format_ && options_.unify_dictionaries) { |
| 1238 | ARROW_ASSIGN_OR_RAISE(auto unified_table, |
| 1239 | DictionaryUnifier::UnifyTable(table, options_.memory_pool)); |
| 1240 | return RecordBatchWriter::WriteTable(*unified_table, max_chunksize); |
| 1241 | } else { |
| 1242 | return RecordBatchWriter::WriteTable(table, max_chunksize); |
| 1243 | } |
| 1244 | } |
| 1245 | |
| 1246 | Status Close() override { |
| 1247 | RETURN_NOT_OK(CheckStarted()); |
no outgoing calls