| 712 | class KernelExecutorImpl : public KernelExecutor { |
| 713 | public: |
| 714 | Status Init(KernelContext* kernel_ctx, KernelInitArgs args) override { |
| 715 | kernel_ctx_ = kernel_ctx; |
| 716 | kernel_ = static_cast<const KernelType*>(args.kernel); |
| 717 | |
| 718 | // Resolve the output type for this kernel |
| 719 | ARROW_ASSIGN_OR_RAISE( |
| 720 | output_type_, kernel_->signature->out_type().Resolve(kernel_ctx_, args.inputs)); |
| 721 | |
| 722 | return Status::OK(); |
| 723 | } |
| 724 | |
| 725 | protected: |
| 726 | // Prepare an output ArrayData to be written to. If |
nothing calls this directly
no test coverage detected