| 854 | } |
| 855 | |
| 856 | Status UnpackSchemaMessage(const void* opaque_schema, const IpcReadOptions& options, |
| 857 | DictionaryMemo* dictionary_memo, |
| 858 | std::shared_ptr<Schema>* schema, |
| 859 | std::shared_ptr<Schema>* out_schema, |
| 860 | std::vector<bool>* field_inclusion_mask, bool* swap_endian) { |
| 861 | RETURN_NOT_OK(internal::GetSchema(opaque_schema, dictionary_memo, schema)); |
| 862 | |
| 863 | // If we are selecting only certain fields, populate the inclusion mask now |
| 864 | // for fast lookups |
| 865 | RETURN_NOT_OK(GetInclusionMaskAndOutSchema(*schema, options.included_fields, |
| 866 | field_inclusion_mask, out_schema)); |
| 867 | *swap_endian = options.ensure_native_endian && !out_schema->get()->is_native_endian(); |
| 868 | if (*swap_endian) { |
| 869 | // create a new schema with native endianness before swapping endian in ArrayData |
| 870 | *schema = schema->get()->WithEndianness(Endianness::Native); |
| 871 | *out_schema = out_schema->get()->WithEndianness(Endianness::Native); |
| 872 | } |
| 873 | return Status::OK(); |
| 874 | } |
| 875 | |
| 876 | Status UnpackSchemaMessage(const Message& message, const IpcReadOptions& options, |
| 877 | DictionaryMemo* dictionary_memo, |
no test coverage detected