| 825 | |
| 826 | protected: |
| 827 | Status EmitResult(std::shared_ptr<ArrayData> out, ExecListener* listener) { |
| 828 | if (span_iterator_.have_all_scalars()) { |
| 829 | // ARROW-16757 We boxed scalar inputs as ArraySpan, so now we have to |
| 830 | // unbox the output as a scalar |
| 831 | ARROW_ASSIGN_OR_RAISE(std::shared_ptr<Scalar> scalar, MakeArray(out)->GetScalar(0)); |
| 832 | return listener->OnResult(std::move(scalar)); |
| 833 | } else { |
| 834 | return listener->OnResult(std::move(out)); |
| 835 | } |
| 836 | } |
| 837 | |
| 838 | Status ExecuteSpans(ExecListener* listener) { |
| 839 | // We put the preallocation in an ArraySpan to be passed to the |
nothing calls this directly
no test coverage detected