首页 > 基础资料 博客日记

leveldb-Impl: SnapshotSeekingIterator.java

2023-07-25 18:40:26基础资料围观246次

Java资料网推荐leveldb-Impl: SnapshotSeekingIterator.java这篇文章给大家，欢迎收藏Java资料网享受知识的乐趣

SnapshotSeekingIterator.java

public final class SnapshotSeekingIterator
        extends AbstractSeekingIterator<Slice, Slice>
{
    private final DbIterator iterator;
    private final SnapshotImpl snapshot;
    private final Comparator<Slice> userComparator;

继承AbstractSeekingIterator接口  实现迭代器和比较器。

public SnapshotSeekingIterator(DbIterator iterator, SnapshotImpl snapshot, Comparator<Slice> userComparator)
    {
        this.iterator = iterator;
        this.snapshot = snapshot;
        this.userComparator = userComparator;
        this.snapshot.getVersion().retain();
    }

获取迭代器，比较器，snapshot和snapshot的version

public void close()
    {
        this.snapshot.getVersion().release();
    }

关闭snapshot调用release

 @Override
    protected void seekToFirstInternal()
    {
        iterator.seekToFirst();
        findNextUserEntry(null);
    }

寻找第一个Internal key的snapshot快照版本

@Override
    protected void seekInternal(Slice targetKey)
    {
        iterator.seek(new InternalKey(targetKey, snapshot.getLastSequence(), ValueType.VALUE));
        findNextUserEntry(null);
    }

寻找Internal key，获取targetKey,snapshot的lastSequence和ValueType

UserKey是读写键值对时提供的键，只是一个简单的字符串，用slice表示。Internal Key是SSTable里实际存储的键值，由targetKey  SequenceNumber和ValueType组成的。

Internal Key在User Key的后面增加了一个64位的整数，并且将这个整数分为两部分，低位的一个字节是一个ValueType，高位的7个字节是一个SequenceNumber.

ValueTyp是为了区分一个键是插入还是删除，删除其实也是一条数据的插入，但是是一条特殊的插入，通过在User Key后面附上kTypeDeletion来说明要删除这个键，kTypeValue说明是插入这个键。

SequenceNumber是一个版本号，是全局的，每次有一个键写入时，都会加一，每一个Internal Key里面都包含了不同的SequenceNumber。SequenceNumber是单调递增的，SequenceNumber越大，表示这键越新，如果User Key相同，就会覆盖旧的键。所以就算User Key相同，对应的Internal Key也是不同的，Internal Key是全局唯一的。当我们更新一个User Key多次时，数据库里面可能保存了多个User Key，但是它们所在的Internal Key是不同的，并且SequenceNumber可以决定写入的顺序。

当用户写入时，将User Key封装成Internal Key，保留版本信息，存储到SSTable里，当需要读取时，将User Key从Internal Key里提取出来，所有User Key相同的Internal Key里面SequenceNumber最大的Internal Key就是当前的键，它对应的值就是当前值。

@Override
    protected Entry<Slice, Slice> getNextElement()
    {
        if (!iterator.hasNext()) {
            return null;
        }

        Entry<InternalKey, Slice> next = iterator.next();

        // find the next user entry after the key we are about to return
        findNextUserEntry(next.getKey().getUserKey());

        return Maps.immutableEntry(next.getKey().getUserKey(), next.getValue());
    }

先判断迭代器是否有下一个元素，再获取Entry<Slice,Slice>的下一个Element   返回immutableEntry的Userkey和Value

private void findNextUserEntry(Slice deletedKey)
    {
        // if there are no more entries, we are done
        if (!iterator.hasNext()) {
            return;
        }

        do {
            // Peek the next entry and parse the key
            InternalKey internalKey = iterator.peek().getKey();

            // skip entries created after our snapshot
            if (internalKey.getSequenceNumber() > snapshot.getLastSequence()) {
                iterator.next();
                continue;
            }

            // if the next entry is a deletion, skip all subsequent entries for that key
            if (internalKey.getValueType() == ValueType.DELETION) {
                deletedKey = internalKey.getUserKey();
            }
            else if (internalKey.getValueType() == ValueType.VALUE) {
                // is this value masked by a prior deletion record?
                if (deletedKey == null || userComparator.compare(internalKey.getUserKey(), deletedKey) > 0) {
                    return;
                }
            }
            iterator.next();
        } while (iterator.hasNext());
    }

寻找被删除Key的下一个Userkey

@Override
    public String toString()
    {
        final StringBuilder sb = new StringBuilder();
        sb.append("SnapshotSeekingIterator");
        sb.append("{snapshot=").append(snapshot);
        sb.append(", iterator=").append(iterator);
        sb.append('}');
        return sb.toString();
    }

把snapshot和iterator转化为String

参考：[LevelDB] 数据库2：所见非所得 —— 三种Key - 知乎 (zhihu.com)


文章来源:https://www.cnblogs.com/yunqihao/p/16498712.html
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：jacktools123@163.com进行投诉反馈，一经查实，立即删除！

标签：

上一篇：Java List的stream内存分页
下一篇：Day3 java

相关文章

最新发布

点击排行

本站推荐

标签云