Function CompareFuzzBatches

cpp/src/arrow/ipc/reader.cc:2698–2743

}

Status CompareFuzzBatches(const RecordBatchWithMetadata& left,
                          const RecordBatchWithMetadata& right) {
  if ((left.custom_metadata != nullptr) != (right.custom_metadata != nullptr) ||
      (left.custom_metadata && !left.custom_metadata->Equals(*right.custom_metadata))) {
    std::stringstream ss;
    auto print_metadata = [&](const RecordBatchWithMetadata& batch) {
      if (batch.custom_metadata) {
        ss << batch.custom_metadata->ToString();
      } else {
        ss << "nullptr";
      }
    };
    ss << "Custom metadata unequal: left = ";
    print_metadata(left);
    ss << "\nright = ";
    print_metadata(right);
    return Status::Invalid(ss.str());
  }

  bool ok = true;
  if ((left.batch != nullptr) != (right.batch != nullptr)) {
    ok = false;
  } else if (left.batch) {
    ok &= left.batch->Equals(*right.batch, EqualOptions{}.nans_equal(true));
  }
  if (ok) {
    return Status::OK();
  }
  std::stringstream ss;
  PrettyPrintOptions options{};
  options.show_field_metadata = true;
  options.show_schema_metadata = true;
  auto print_batch = [&](const RecordBatchWithMetadata& batch) {
    if (batch.batch) {
      ss << "\n";
      ARROW_UNUSED(PrettyPrint(*batch.batch, options, &ss));
    } else {
      ss << "nullptr";
    }
  };
  ss << "Batches unequal: left = ";
  print_batch(left);
  ss << "\nright = ";
  print_batch(right);
  return Status::Invalid(ss.str());
}

Status CompareFuzzBatches(const std::vector<RecordBatchWithMetadata>& left,
                          const std::vector<RecordBatchWithMetadata>& right) {