| 1665 | } |
| 1666 | |
| 1667 | Status ReadOneDictionary(int dict_index, Message* message, |
| 1668 | const IpcReadContext& context) { |
| 1669 | CHECK_HAS_BODY(*message); |
| 1670 | ARROW_ASSIGN_OR_RAISE(auto reader, Buffer::GetReader(message->body())); |
| 1671 | DictionaryKind kind; |
| 1672 | RETURN_NOT_OK(ReadDictionary(*message->metadata(), context, &kind, reader.get())); |
| 1673 | if (kind == DictionaryKind::Replacement) { |
| 1674 | return Status::Invalid("Unsupported dictionary replacement in IPC file"); |
| 1675 | } else if (kind == DictionaryKind::Delta) { |
| 1676 | stats_.num_dictionary_deltas.fetch_add(1, std::memory_order_relaxed); |
| 1677 | } |
| 1678 | stats_.num_dictionary_batches.fetch_add(1, std::memory_order_relaxed); |
| 1679 | return Status::OK(); |
| 1680 | } |
| 1681 | |
| 1682 | Status AddDictionaryRanges(std::vector<io::ReadRange>* ranges) const { |
| 1683 | // Adds all dictionaries to the range cache |
nothing calls this directly
no test coverage detected