Method Init

storage/sstable/reader/in_memory_sstable_reader.cpp:20–45

}

void InMemorySSTableReader::Init() {
    cached_block_.reset(new hfile::DataBlock(impl_->file_trailer_->compress_type()));
    std::vector<std::string> values;
    std::string ori_key = "";
    for (int block_id = 0; block_id < impl_->file_trailer_->data_index_count(); block_id++) {
        impl_->LoadDataBlock(block_id, cached_block_.get());
        for (int data_idx = 0; data_idx < cached_block_->GetDataItemSize(); data_idx++) {
            if (block_id == 0 && data_idx == 0) {
                ori_key = cached_block_->GetKey(0);
            }
            std::string key = cached_block_->GetKey(data_idx);
            std::string value = cached_block_->GetValue(data_idx);
            if (key != ori_key) {
                data_.push_back(make_pair(ori_key, values));
                ori_key = key;
                values.clear();
            }
            values.push_back(value);
        }
    }
    data_.push_back(make_pair(ori_key, values));
//  index_.resize(data_.size() * 2);
    for (DataVector::iterator it = data_.begin(); it != data_.end(); it++) {
        index_.insert(make_pair(it->first, it));
    }
}

InMemoryIterator::InMemoryIterator(InMemorySSTableReader *sstable, const std::string &key)
                : sstable_(sstable) {