Method CountJsonObjects

be/src/exec/json/json-parser.cc:139–167

template <class Scanner>
Status JsonParser<Scanner>::CountJsonObjects(int max_rows, int* num_rows) {
  JsonSkipper<CharStream> skipper(stream_);
  while (*num_rows < max_rows) {
    skipper.SkipNextObject();

    if (UNLIKELY(skipper.HasError())) {
      if (skipper.GetErrorCode() == kParseErrorDocumentEmpty) {
        // See the comments at the corresponding location of the Parse().
        if (UNLIKELY(!stream_.Eos())) {
          DCHECK_EQ(stream_.Peek(), '\0');
          stream_.Take();
          continue;
        }
        return Status::OK();
      }
      RETURN_IF_ERROR(scanner_->HandleError(skipper.GetErrorCode(), stream_.Tell()));

      // See the comments at the corresponding location of the Parse().
      if (reader_.GetParseErrorCode() != kParseErrorObjectMissCommaOrCurlyBracket) {
        MoveToNextJson();
      }
    }

    ++(*num_rows);
    if (UNLIKELY(scanner_->BreakParse())) break;
  }

  return Status::OK();
}

template <class Scanner>
bool JsonParser<Scanner>::Key(const char* str, uint32_t len, bool copy) {