| 415 | } |
| 416 | |
| 417 | Status NdarraysToSparseCOOTensor(MemoryPool* pool, PyObject* data_ao, PyObject* coords_ao, |
| 418 | const std::vector<int64_t>& shape, |
| 419 | const std::vector<std::string>& dim_names, |
| 420 | std::shared_ptr<SparseCOOTensor>* out) { |
| 421 | if (!PyArray_Check(data_ao) || !PyArray_Check(coords_ao)) { |
| 422 | return Status::TypeError("Did not pass ndarray object"); |
| 423 | } |
| 424 | |
| 425 | PyArrayObject* ndarray_data = reinterpret_cast<PyArrayObject*>(data_ao); |
| 426 | std::shared_ptr<Buffer> data = std::make_shared<NumPyBuffer>(data_ao); |
| 427 | ARROW_ASSIGN_OR_RAISE( |
| 428 | auto type_data, |
| 429 | GetTensorType(reinterpret_cast<PyObject*>(PyArray_DESCR(ndarray_data)))); |
| 430 | |
| 431 | std::shared_ptr<Tensor> coords; |
| 432 | RETURN_NOT_OK(NdarrayToTensor(pool, coords_ao, {}, &coords)); |
| 433 | ARROW_CHECK_EQ(coords->type_id(), Type::INT64); // Should be ensured by caller |
| 434 | |
| 435 | ARROW_ASSIGN_OR_RAISE(std::shared_ptr<SparseCOOIndex> sparse_index, |
| 436 | SparseCOOIndex::Make(coords)); |
| 437 | *out = std::make_shared<SparseTensorImpl<SparseCOOIndex>>(sparse_index, type_data, data, |
| 438 | shape, dim_names); |
| 439 | return Status::OK(); |
| 440 | } |
| 441 | |
| 442 | template <class IndexType> |
| 443 | Status NdarraysToSparseCSXMatrix(MemoryPool* pool, PyObject* data_ao, PyObject* indptr_ao, |
nothing calls this directly
no test coverage detected