Method FetchTuple

contrib/pax_storage/src/cpp/access/pax_scanner.cc:120–148

PaxIndexScanDesc::~PaxIndexScanDesc() {}

bool PaxIndexScanDesc::FetchTuple(ItemPointer tid, Snapshot snapshot,
                                  TupleTableSlot *slot, bool *call_again,
                                  bool *all_dead) {
  BlockNumber block = pax::GetBlockNumber(*tid);
  if (block != current_block_ || !reader_) {
    if (!OpenMicroPartition(block, snapshot)) return false;
  }

  Assert(current_block_ == block && reader_);
  if (call_again) *call_again = false;
  if (all_dead) *all_dead = false;

  try {
    ExecClearTuple(slot);
    if (CheckExists(GetRelation(), tid, snapshot, all_dead) &&
        reader_->GetTuple(slot, pax::GetTupleOffset(*tid))) {
      SetBlockNumber(&slot->tts_tid, block);
      ExecStoreVirtualTuple(slot);

      return true;
    }
  } catch (cbdb::CException &e) {
    e.AppendDetailMessage(
        fmt("\n FetchTuple [tid=%s]", ItemPointerToString(tid)));
    CBDB_RERAISE(e);
  }

  return false;
}

bool PaxIndexScanDesc::OpenMicroPartition(BlockNumber block,
                                          Snapshot snapshot) {