| 1059 | |
| 1060 | private: |
| 1061 | Status OnSchemaMessageDecoded(std::unique_ptr<Message> message) { |
| 1062 | RETURN_NOT_OK(UnpackSchemaMessage(*message, options_, &dictionary_memo_, &schema_, |
| 1063 | &filtered_schema_, &field_inclusion_mask_, |
| 1064 | &swap_endian_)); |
| 1065 | |
| 1066 | num_required_initial_dictionaries_ = dictionary_memo_.fields().num_dicts(); |
| 1067 | num_read_initial_dictionaries_ = 0; |
| 1068 | if (num_required_initial_dictionaries_ == 0) { |
| 1069 | state_ = State::RECORD_BATCHES; |
| 1070 | RETURN_NOT_OK(listener_->OnSchemaDecoded(schema_, filtered_schema_)); |
| 1071 | } else { |
| 1072 | state_ = State::INITIAL_DICTIONARIES; |
| 1073 | } |
| 1074 | return Status::OK(); |
| 1075 | } |
| 1076 | |
| 1077 | Status OnInitialDictionaryMessageDecoded(std::unique_ptr<Message> message) { |
| 1078 | if (message->type() != MessageType::DICTIONARY_BATCH) { |
nothing calls this directly
no test coverage detected