Method compare

bolt/exec/Spill.cpp:48–66

}

int32_t SpillMergeStream::compare(const MergeStream& other) const {
  BOLT_CHECK(!closed_);
  const auto& otherStream = static_cast<const SpillMergeStream&>(other);
  const auto& children = rowVector_->children();
  const auto& otherChildren = otherStream.current().children();
  for (const auto& [key, compareFlags] : sortingKeys()) {
    const auto result = children[key]
                            ->compare(
                                otherChildren[key].get(),
                                index_,
                                otherStream.index_,
                                compareFlags)
                            .value();
    if (result != 0) {
      return result;
    }
  }
  return 0;
}

void SpillMergeStream::close() {
  BOLT_CHECK(!closed_);