Method Exec

cpp/src/arrow/compute/kernels/vector_statistics.cc:64–78

  using CType = typename TypeTraits<Type>::CType;

  static Status Exec(KernelContext* ctx, const ExecSpan& batch, ExecResult* out) {
    const auto& options = WinsorizeState::Get(ctx);
    RETURN_NOT_OK(ValidateOptions(options));
    auto data = batch.values[0].array.ToArrayData();
    ARROW_ASSIGN_OR_RAISE(auto maybe_quantiles, GetQuantileValues(ctx, data, options));
    auto out_data = out->array_data_mutable();
    if (!maybe_quantiles.has_value()) {
      // Only nulls and NaNs => return input as-is
      out_data->null_count = data->null_count.load();
      out_data->length = data->length;
      out_data->buffers = data->buffers;
      return Status::OK();
    }
    return ClipValues(*data, maybe_quantiles.value(), out_data, ctx);
  }

  static Status ExecChunked(KernelContext* ctx, const ExecBatch& batch, Datum* out) {
    const auto& options = WinsorizeState::Get(ctx);