| 957 | } |
| 958 | |
| 959 | Status SchemaToFlatbuffer(FBB& fbb, const Schema& schema, |
| 960 | const DictionaryFieldMapper& mapper, |
| 961 | flatbuffers::Offset<flatbuf::Schema>* out) { |
| 962 | std::vector<FieldOffset> field_offsets; |
| 963 | FieldPosition pos; |
| 964 | for (int i = 0; i < schema.num_fields(); ++i) { |
| 965 | FieldOffset offset; |
| 966 | FieldToFlatbufferVisitor field_visitor(fbb, mapper, pos.child(i)); |
| 967 | RETURN_NOT_OK(field_visitor.GetResult(schema.field(i), &offset)); |
| 968 | field_offsets.push_back(offset); |
| 969 | } |
| 970 | |
| 971 | auto fb_offsets = fbb.CreateVector(field_offsets); |
| 972 | auto fb_endianness = schema.endianness() == Endianness::Little |
| 973 | ? flatbuf::Endianness::Endianness_Little |
| 974 | : flatbuf::Endianness::Endianness_Big; |
| 975 | *out = flatbuf::CreateSchema(fbb, fb_endianness, fb_offsets, |
| 976 | SerializeCustomMetadata(fbb, schema.metadata())); |
| 977 | return Status::OK(); |
| 978 | } |
| 979 | |
| 980 | Result<std::shared_ptr<Buffer>> WriteFBMessage( |
| 981 | FBB& fbb, flatbuf::MessageHeader header_type, flatbuffers::Offset<void> header, |
no test coverage detected