| 277 | } |
| 278 | |
| 279 | Status IndicesNonZeroExecChunked(KernelContext* ctx, const ExecBatch& batch, Datum* out) { |
| 280 | const ChunkedArray& arr = *batch[0].chunked_array(); |
| 281 | std::vector<ArraySpan> arrays; |
| 282 | for (int i = 0; i < arr.num_chunks(); ++i) { |
| 283 | arrays.push_back(ArraySpan(*arr.chunk(i)->data())); |
| 284 | } |
| 285 | std::shared_ptr<ArrayData> result; |
| 286 | RETURN_NOT_OK(DoNonZero(arrays, arr.length(), &result)); |
| 287 | out->value = std::move(result); |
| 288 | return Status::OK(); |
| 289 | } |
| 290 | |
| 291 | std::shared_ptr<VectorFunction> MakeIndicesNonZeroFunction(std::string name, |
| 292 | FunctionDoc doc) { |
nothing calls this directly
no test coverage detected