| 1082 | } // namespace internal |
| 1083 | |
| 1084 | Status WriteSparseTensor(const SparseTensor& sparse_tensor, io::OutputStream* dst, |
| 1085 | int32_t* metadata_length, int64_t* body_length) { |
| 1086 | IpcPayload payload; |
| 1087 | internal::SparseTensorSerializer writer(0, &payload); |
| 1088 | RETURN_NOT_OK(writer.Assemble(sparse_tensor)); |
| 1089 | |
| 1090 | *body_length = payload.body_length; |
| 1091 | return WriteIpcPayload(payload, IpcWriteOptions::Defaults(), dst, metadata_length); |
| 1092 | } |
| 1093 | |
| 1094 | Status GetSparseTensorPayload(const SparseTensor& sparse_tensor, MemoryPool* pool, |
| 1095 | IpcPayload* out) { |