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