Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/burhanxz/Distributed-KV
/ functions
Functions
669 in github.com/burhanxz/Distributed-KV
⨍
Functions
669
◇
Types & classes
178
↓ 58 callers
Method
get
在当前level的所有文件里查找key @param key 查找的key @return 查找结果 @throws Exception
lsm/src/lsm/Level.java:22
↓ 36 callers
Method
add
(long seq, InternalKeyType type, ByteBuf key, ByteBuf value)
lsm/src/lsm/MemTable.java:13
↓ 36 callers
Method
size
获取memtable数据量大小, 单位: B @return
lsm/src/lsm/MemTable.java:18
↓ 34 callers
Method
put
写入数据 @param key @param value @throws IOException
lsm/src/lsm/Engine.java:17
↓ 31 callers
Method
get
(InetSocketAddress address)
rpc/src/rpc/connector/InvokerFactory.java:9
↓ 19 callers
Method
getValue
获取正常返回结果 @return
rpc/src/rpc/Result.java:18
↓ 19 callers
Method
next
()
lsm/src/lsm/internal/BlockImpl.java:77
↓ 18 callers
Method
hasNext
()
lsm/src/lsm/internal/BlockImpl.java:72
↓ 17 callers
Method
buf2Str
ByteBuf内容生成字符串 @param buf @return
lsm/src/lsm/base/ByteBufUtils.java:104
↓ 17 callers
Method
getUserKey
()
lsm/src/lsm/base/LookupKey.java:21
↓ 15 callers
Method
iterator
()
lsm/src/lsm/SeekingIterable.java:13
↓ 15 callers
Method
lock
@param lockName redis key的名字,即锁名 @return 返回一个lockSerialNumber(uuid)或null,如果加锁成功,则为uuid,以此为凭据进行解锁动作
rpc/src/rpc/lock/DistributedLock.java:14
↓ 14 callers
Method
getKey
()
lsm/src/lsm/internal/EngineImpl.java:730
↓ 13 callers
Method
isEmpty
判断memtable是否为空 @return
lsm/src/lsm/MemTable.java:24
↓ 12 callers
Method
build
()
rpc/src/rpc/Invocation.java:40
↓ 12 callers
Method
getName
()
rpc/src/rpc/provide/NameService.java:4
↓ 12 callers
Method
getNumber
()
lsm/src/lsm/base/FileMetaData.java:65
↓ 11 callers
Method
getFiles
获取本层所有的文件 @return
lsm/src/lsm/Level.java:27
↓ 11 callers
Method
getLargest
()
lsm/src/lsm/base/FileMetaData.java:77
↓ 10 callers
Method
decode
反序列化得到internal key对象,字节数据不包含大小信息 @param byteBuf 字节数据 @return internal key对象
lsm/src/lsm/base/InternalKey.java:57
↓ 9 callers
Method
getSmallest
()
lsm/src/lsm/base/FileMetaData.java:73
↓ 9 callers
Method
write
将buffer中的数据写入文件 @param channel @param buffer @throws IOException
lsm/src/lsm/base/ByteBufUtils.java:25
↓ 8 callers
Method
addFile
设置增加的文件信息 @param level 增加文件所属level @param fileMetaData 增加文件的信息
lsm/src/lsm/internal/VersionEdit.java:218
↓ 8 callers
Method
builder
()
rpc/src/rpc/URL.java:21
↓ 8 callers
Method
getKey
()
lsm/src/lsm/base/LookupResult.java:29
↓ 8 callers
Method
invoke
(Class<?> interfaceClazz, Method method, Object[] parameters)
rpc/src/rpc/connector/Invoker.java:15
↓ 8 callers
Method
key
(String str)
example/src/lsm/VersionTest.java:72
↓ 8 callers
Method
str2Buf
字符串转byteBuf @param str @return
lsm/src/lsm/base/ByteBufUtils.java:121
↓ 7 callers
Method
close
()
lsm/src/lsm/internal/SSTableImpl.java:144
↓ 7 callers
Method
deleteFile
设置被删除的文件信息 @param level 被删文件所属level @param fileNumber 被删文件编号
lsm/src/lsm/internal/VersionEdit.java:205
↓ 7 callers
Method
encode
将versionEdit编码为字节,方便序列化.序列化结构参考VersionEdit doc @return 字节数据
lsm/src/lsm/internal/VersionEdit.java:80
↓ 7 callers
Method
getInternalKey
(long seq)
lsm/src/lsm/internal/EngineImpl.java:736
↓ 7 callers
Method
getLogNumber
()
lsm/src/lsm/internal/VersionEdit.java:258
↓ 7 callers
Method
getPath
()
rpc/src/rpc/URL.java:86
↓ 7 callers
Method
getState
返回状态码 @return
lsm/src/lsm/base/InternalKey.java:170
↓ 7 callers
Method
getType
获取internal key 类型 @return
lsm/src/lsm/base/InternalKey.java:148
↓ 7 callers
Method
putVarByte
(ByteBuf dst, byte data)
lsm/src/lsm/base/ByteBufUtils.java:49
↓ 6 callers
Method
builder
()
rpc/src/rpc/impl/InvocationImpl.java:18
↓ 6 callers
Method
compareTo
(Router o)
rpc/src/rpc/impl/RouterImpl.java:12
↓ 6 callers
Method
getEdit
获取所属edit @return
lsm/src/lsm/base/Compaction.java:80
↓ 6 callers
Method
getUserKey
获取实际key @return
lsm/src/lsm/base/InternalKey.java:134
↓ 6 callers
Method
putVarLong
(ByteBuf dst, long data)
lsm/src/lsm/base/ByteBufUtils.java:57
↓ 6 callers
Method
read
读取文件数据到ByteBuf中 @param channel @param buffer @throws IOException
lsm/src/lsm/base/ByteBufUtils.java:40
↓ 6 callers
Method
remove
(InetSocketAddress address)
rpc/src/rpc/connector/InvokerFactory.java:13
↓ 5 callers
Method
addRecord
将记录写入日志 @param record 信息记录 @param force 是否同步刷盘 @throws IOException
lsm/src/lsm/LogWriter.java:32
↓ 5 callers
Method
close
()
rpc/src/rpc/service/RpcInvokeHandler.java:122
↓ 5 callers
Method
connectString
返回host:port格式的IP地址 @return
rpc/src/rpc/URL.java:72
↓ 5 callers
Method
finish
结束block builder,写入重启点位置和数量信息 @return 返回字节数据
lsm/src/lsm/BlockBuilder.java:11
↓ 5 callers
Method
getKeys
()
example/src/lsm/Datas.java:23
↓ 5 callers
Method
getNextFileNumber
()
lsm/src/lsm/internal/VersionSetImpl.java:386
↓ 5 callers
Method
getRange
获取所有文件的最终大小范围 @param inputLists @return 最小值和最大值
lsm/src/lsm/internal/VersionSetImpl.java:334
↓ 5 callers
Method
getVarWithLenPrefix
(ByteBuf src)
lsm/src/lsm/base/ByteBufUtils.java:71
↓ 5 callers
Method
putVarWithLenPrefix
(ByteBuf dst, ByteBuf data)
lsm/src/lsm/base/ByteBufUtils.java:61
↓ 5 callers
Method
setComparatorName
(String comparatorName)
lsm/src/lsm/internal/VersionEdit.java:243
↓ 5 callers
Method
setLogNumber
(Long logNumber)
lsm/src/lsm/internal/VersionEdit.java:246
↓ 5 callers
Method
toString
()
rpc/src/rpc/data/IRequest.java:54
↓ 4 callers
Method
compare
(FileMetaData left, FileMetaData right)
lsm/src/lsm/internal/LevelImpl.java:21
↓ 4 callers
Method
getCurrent
获取当前版本 @return
lsm/src/lsm/VersionSet.java:75
↓ 4 callers
Method
getCurrent
()
lsm/src/lsm/internal/VersionSetImpl.java:391
↓ 4 callers
Method
getEdit
(VersionSet versionSet, long logNumber)
example/src/lsm/VersionTest.java:62
↓ 4 callers
Method
getFileSize
获取当前文件实际大小 @return @throws IOException
lsm/src/lsm/SSTableBuilder.java:41
↓ 4 callers
Method
getHandle
handle指的是位置和大小信息 @param offset 偏置,即起始位置 @param size 大小 @return handle的字节数据
lsm/src/lsm/internal/SSTableBuilderImpl.java:185
↓ 4 callers
Method
getHost
@param @return
rpc/src/rpc/cluster/Cluster.java:13
↓ 4 callers
Method
getLevel
获取需要compact的低一层 @return
lsm/src/lsm/base/Compaction.java:88
↓ 4 callers
Method
getOverlappingInputs
寻找第level层和指定范围有重叠的全部文件信息 @param level 层数 @param smallest 最小值 @param largest 最大值 @return 所有重叠文件
lsm/src/lsm/internal/VersionSetImpl.java:365
↓ 4 callers
Method
getPort
()
rpc/src/rpc/model/RegistryBean.java:12
↓ 4 callers
Method
getProviderPath
形如: /appKey/service/providers/IP @param url @return
rpc/src/rpc/impl/ZookeeperRegistry.java:298
↓ 4 callers
Method
hasNext
()
lsm/src/lsm/internal/SSTableImpl.java:180
↓ 4 callers
Method
logAndApply
(VersionEdit edit)
lsm/src/lsm/internal/VersionSetImpl.java:198
↓ 4 callers
Method
makeFileName
(long number, String suffix)
lsm/src/lsm/base/FileUtils.java:75
↓ 4 callers
Method
newSSTableFile
新建sstable文件 @param databaseDir @param fileNumber @return @throws IOException
lsm/src/lsm/base/FileUtils.java:20
↓ 4 callers
Method
next
()
lsm/src/lsm/internal/SSTableImpl.java:190
↓ 4 callers
Method
peek
取出当前指针数据但是不移动指针 @return 当前指针位置数据
lsm/src/lsm/SeekingIterator.java:19
↓ 4 callers
Method
release
减少一次引用计数
lsm/src/lsm/Version.java:46
↓ 4 callers
Method
seek
指针移动到第一个 >= key 的位置 @param key 键 @return
lsm/src/lsm/SeekingIterator.java:26
↓ 4 callers
Method
setLastSequenceNumber
(Long lastSequenceNumber)
lsm/src/lsm/internal/VersionEdit.java:252
↓ 4 callers
Method
setNextFileNumber
(Long nextFileNumber)
lsm/src/lsm/internal/VersionEdit.java:249
↓ 3 callers
Method
addFile
加入文件 @param file
lsm/src/lsm/Level.java:32
↓ 3 callers
Method
appendPath
(String path)
rpc/src/rpc/URL.java:54
↓ 3 callers
Method
appendVersion
将version指定为current,存入version列表 @param version
lsm/src/lsm/internal/VersionSetImpl.java:288
↓ 3 callers
Method
build
根据apply的edit信息,产生一个version对象 @return
lsm/src/lsm/VersionBuilder.java:20
↓ 3 callers
Method
connect
连接获取客户端 @param clientURL @return
rpc/src/rpc/Exchanger.java:15
↓ 3 callers
Method
files
某层中的文件总数 @param level 层编号 @return 文件数目
lsm/src/lsm/Version.java:88
↓ 3 callers
Method
getLastSequenceNumber
()
lsm/src/lsm/internal/VersionEdit.java:264
↓ 3 callers
Method
getLevelInputs
获取低一层需要compact的文件 @return
lsm/src/lsm/base/Compaction.java:72
↓ 3 callers
Method
getMethod
()
rpc/src/rpc/data/IRequest.java:46
↓ 3 callers
Method
getNextElement
核心实现,通过level1迭代器获取level2迭代器,进而获取实际k-v数据 @return
lsm/src/lsm/internal/SSTableImpl.java:279
↓ 3 callers
Method
getNextFileNumber
获取下一个文件编号 @return
lsm/src/lsm/VersionSet.java:70
↓ 3 callers
Method
getNextFileNumber
()
lsm/src/lsm/internal/VersionEdit.java:261
↓ 3 callers
Method
getResult
获取异步数据 @return
rpc/src/rpc/impl/AsyncResult.java:49
↓ 3 callers
Method
getThread
()
lsm/src/lsm/internal/EngineImpl.java:748
↓ 3 callers
Method
getUrl
获取本节点的url @return
rpc/src/rpc/Node.java:8
↓ 3 callers
Method
getValue
()
lsm/src/lsm/internal/EngineImpl.java:733
↓ 3 callers
Method
getValueBytes
()
lsm/src/lsm/base/LookupResult.java:35
↓ 3 callers
Method
getValues
()
example/src/lsm/Datas.java:37
↓ 3 callers
Method
host
(String host)
rpc/src/rpc/URL.java:32
↓ 3 callers
Method
isDone
()
lsm/src/lsm/internal/EngineImpl.java:745
↓ 3 callers
Method
iterator
()
lsm/src/lsm/internal/SSTableImpl.java:138
↓ 3 callers
Method
logAndApply
记录和应用一个edit,来产生一个新的version @param edit @throws IOException
lsm/src/lsm/VersionSet.java:36
↓ 3 callers
Method
maybeCompaction
尝试触发compact,是异步操作
lsm/src/lsm/internal/EngineImpl.java:306
next →
1–100 of 669, ranked by callers