Method Exec

cpp/src/arrow/compute/kernels/scalar_temporal_unary.cc:1267–1328

  }

  static Status Exec(KernelContext* ctx, const ExecSpan& batch, ExecResult* out) {
    const ArraySpan& in = batch[0].array;
    ARROW_ASSIGN_OR_RAISE(auto self, Make(ctx, *in.type));

    ArraySpan* out_span = out->array_span_mutable();
    int64_t* out_data = out_span->GetValues<int64_t>(1);

    if (self.error_is_null) {
      // Set all values to non-null, and only clear bits when there is a
      // parsing error
      bit_util::SetBitmap(out_span->buffers[0].data, out_span->offset, out_span->length);

      int64_t null_count = 0;
      arrow::internal::BitmapWriter out_writer(out_span->buffers[0].data,
                                               out_span->offset, out_span->length);
      auto visit_null = [&]() {
        *out_data++ = 0;
        out_writer.Clear();
        out_writer.Next();
        null_count++;
      };
      auto visit_value = [&](std::string_view s) {
        int64_t result;
        if ((*self.parser)(s.data(), s.size(), self.unit, &result)) {
          *out_data++ = result;
        } else {
          *out_data++ = 0;
          out_writer.Clear();
          null_count++;
        }
        out_writer.Next();
      };
      VisitArraySpanInline<InType>(in, visit_value, visit_null);
      out_writer.Finish();
      out_span->null_count = null_count;
    } else {
      if (in.buffers[0].data != nullptr) {
        ::arrow::internal::CopyBitmap(in.buffers[0].data, in.offset, in.length,
                                      out_span->buffers[0].data, out_span->offset);
      } else {
        // Input is all non-null
        bit_util::SetBitmap(out_span->buffers[0].data, out_span->offset,
                            out_span->length);
      }
      auto visit_null = [&]() {
        *out_data++ = 0;
        return Status::OK();
      };
      auto visit_value = [&](std::string_view s) {
        int64_t result;
        if ((*self.parser)(s.data(), s.size(), self.unit, &result)) {
          *out_data++ = result;
          return Status::OK();
        } else {
          return Status::Invalid("Failed to parse string: '", s, "' as a scalar of type ",
                                 TimestampType(self.unit).ToString());
        }
      };