Method Exec

cpp/src/arrow/compute/kernels/vector_cumulative_ops.cc:158–175

  using OutType = typename CumulativeState::OutType;
  using OutValue = typename GetOutputType<OutType>::T;
  static Status Exec(KernelContext* ctx, const ExecSpan& batch, ExecResult* out) {
    const auto& options = CumulativeOptionsWrapper<OptionsType>::Get(ctx);
    Accumulator<ArgType, CumulativeState> accumulator(ctx);
    if (options.start.has_value()) {
      accumulator.current_state = CumulativeState(options.start.value());
    } else {
      accumulator.current_state = CumulativeState();
    }
    accumulator.skip_nulls = options.skip_nulls;

    RETURN_NOT_OK(accumulator.builder.Reserve(batch.length));
    RETURN_NOT_OK(accumulator.Accumulate(batch[0].array));

    std::shared_ptr<ArrayData> result;
    RETURN_NOT_OK(accumulator.builder.FinishInternal(&result));
    out->value = std::move(result);
    return Status::OK();
  }
};

template <typename ArgType, typename CumulativeState, typename OptionsType>