Method ProcessBuildBatch

be/src/exec/iceberg-delete-builder.cc:332–364

}

Status IcebergDeleteBuilder::ProcessBuildBatch(RuntimeState* state,
    RowBatch* build_batch) {
  if (UNLIKELY(build_batch->num_rows() == 0)) return Status::OK();

  TupleRow* first_row = build_batch->GetRow(0);
  impala::StringValue* file_path =
      first_row->GetTuple(0)->GetStringSlot(file_path_offset_);
  uint64_t pos = *first_row->GetTuple(0)->GetBigIntSlot(pos_offset_);

  StringValue prev_file_path(*file_path);
  vector<uint64_t> pos_buffer;
  pos_buffer.reserve(128);
  pos_buffer.push_back(pos);

  FOREACH_ROW(build_batch, 1, build_batch_iter) {
    TupleRow* build_row = build_batch_iter.Get();

    file_path = build_row->GetTuple(0)->GetStringSlot(file_path_offset_);
    pos = *build_row->GetTuple(0)->GetBigIntSlot(pos_offset_);

    if (file_path->Ptr() == prev_file_path.Ptr() || *file_path == prev_file_path) {
      pos_buffer.push_back(pos);
    } else {
      RETURN_IF_ERROR(AddToDeletedRows(prev_file_path, pos_buffer));
      pos_buffer.clear();
      pos_buffer.push_back(pos);
      prev_file_path.Assign(*file_path);
    }
  }
  RETURN_IF_ERROR(AddToDeletedRows(prev_file_path, pos_buffer));

  return Status::OK();
}