MCPcopy Create free account

hub / github.com/burhanxz/Distributed-KV / functions

Functions669 in github.com/burhanxz/Distributed-KV

↓ 58 callersMethodget
在当前level的所有文件里查找key @param key 查找的key @return 查找结果 @throws Exception
lsm/src/lsm/Level.java:22
↓ 36 callersMethodadd
(long seq, InternalKeyType type, ByteBuf key, ByteBuf value)
lsm/src/lsm/MemTable.java:13
↓ 36 callersMethodsize
获取memtable数据量大小, 单位: B @return
lsm/src/lsm/MemTable.java:18
↓ 34 callersMethodput
写入数据 @param key @param value @throws IOException
lsm/src/lsm/Engine.java:17
↓ 31 callersMethodget
(InetSocketAddress address)
rpc/src/rpc/connector/InvokerFactory.java:9
↓ 19 callersMethodgetValue
获取正常返回结果 @return
rpc/src/rpc/Result.java:18
↓ 19 callersMethodnext
()
lsm/src/lsm/internal/BlockImpl.java:77
↓ 18 callersMethodhasNext
()
lsm/src/lsm/internal/BlockImpl.java:72
↓ 17 callersMethodbuf2Str
ByteBuf内容生成字符串 @param buf @return
lsm/src/lsm/base/ByteBufUtils.java:104
↓ 17 callersMethodgetUserKey
()
lsm/src/lsm/base/LookupKey.java:21
↓ 15 callersMethoditerator
()
lsm/src/lsm/SeekingIterable.java:13
↓ 15 callersMethodlock
@param lockName redis key的名字,即锁名 @return 返回一个lockSerialNumber(uuid)或null,如果加锁成功,则为uuid,以此为凭据进行解锁动作
rpc/src/rpc/lock/DistributedLock.java:14
↓ 14 callersMethodgetKey
()
lsm/src/lsm/internal/EngineImpl.java:730
↓ 13 callersMethodisEmpty
判断memtable是否为空 @return
lsm/src/lsm/MemTable.java:24
↓ 12 callersMethodbuild
()
rpc/src/rpc/Invocation.java:40
↓ 12 callersMethodgetName
()
rpc/src/rpc/provide/NameService.java:4
↓ 12 callersMethodgetNumber
()
lsm/src/lsm/base/FileMetaData.java:65
↓ 11 callersMethodgetFiles
获取本层所有的文件 @return
lsm/src/lsm/Level.java:27
↓ 11 callersMethodgetLargest
()
lsm/src/lsm/base/FileMetaData.java:77
↓ 10 callersMethoddecode
反序列化得到internal key对象,字节数据不包含大小信息 @param byteBuf 字节数据 @return internal key对象
lsm/src/lsm/base/InternalKey.java:57
↓ 9 callersMethodgetSmallest
()
lsm/src/lsm/base/FileMetaData.java:73
↓ 9 callersMethodwrite
将buffer中的数据写入文件 @param channel @param buffer @throws IOException
lsm/src/lsm/base/ByteBufUtils.java:25
↓ 8 callersMethodaddFile
设置增加的文件信息 @param level 增加文件所属level @param fileMetaData 增加文件的信息
lsm/src/lsm/internal/VersionEdit.java:218
↓ 8 callersMethodbuilder
()
rpc/src/rpc/URL.java:21
↓ 8 callersMethodgetKey
()
lsm/src/lsm/base/LookupResult.java:29
↓ 8 callersMethodinvoke
(Class<?> interfaceClazz, Method method, Object[] parameters)
rpc/src/rpc/connector/Invoker.java:15
↓ 8 callersMethodkey
(String str)
example/src/lsm/VersionTest.java:72
↓ 8 callersMethodstr2Buf
字符串转byteBuf @param str @return
lsm/src/lsm/base/ByteBufUtils.java:121
↓ 7 callersMethodclose
()
lsm/src/lsm/internal/SSTableImpl.java:144
↓ 7 callersMethoddeleteFile
设置被删除的文件信息 @param level 被删文件所属level @param fileNumber 被删文件编号
lsm/src/lsm/internal/VersionEdit.java:205
↓ 7 callersMethodencode
将versionEdit编码为字节,方便序列化.序列化结构参考VersionEdit doc @return 字节数据
lsm/src/lsm/internal/VersionEdit.java:80
↓ 7 callersMethodgetInternalKey
(long seq)
lsm/src/lsm/internal/EngineImpl.java:736
↓ 7 callersMethodgetLogNumber
()
lsm/src/lsm/internal/VersionEdit.java:258
↓ 7 callersMethodgetPath
()
rpc/src/rpc/URL.java:86
↓ 7 callersMethodgetState
返回状态码 @return
lsm/src/lsm/base/InternalKey.java:170
↓ 7 callersMethodgetType
获取internal key 类型 @return
lsm/src/lsm/base/InternalKey.java:148
↓ 7 callersMethodputVarByte
(ByteBuf dst, byte data)
lsm/src/lsm/base/ByteBufUtils.java:49
↓ 6 callersMethodbuilder
()
rpc/src/rpc/impl/InvocationImpl.java:18
↓ 6 callersMethodcompareTo
(Router o)
rpc/src/rpc/impl/RouterImpl.java:12
↓ 6 callersMethodgetEdit
获取所属edit @return
lsm/src/lsm/base/Compaction.java:80
↓ 6 callersMethodgetUserKey
获取实际key @return
lsm/src/lsm/base/InternalKey.java:134
↓ 6 callersMethodputVarLong
(ByteBuf dst, long data)
lsm/src/lsm/base/ByteBufUtils.java:57
↓ 6 callersMethodread
读取文件数据到ByteBuf中 @param channel @param buffer @throws IOException
lsm/src/lsm/base/ByteBufUtils.java:40
↓ 6 callersMethodremove
(InetSocketAddress address)
rpc/src/rpc/connector/InvokerFactory.java:13
↓ 5 callersMethodaddRecord
将记录写入日志 @param record 信息记录 @param force 是否同步刷盘 @throws IOException
lsm/src/lsm/LogWriter.java:32
↓ 5 callersMethodclose
()
rpc/src/rpc/service/RpcInvokeHandler.java:122
↓ 5 callersMethodconnectString
返回host:port格式的IP地址 @return
rpc/src/rpc/URL.java:72
↓ 5 callersMethodfinish
结束block builder,写入重启点位置和数量信息 @return 返回字节数据
lsm/src/lsm/BlockBuilder.java:11
↓ 5 callersMethodgetKeys
()
example/src/lsm/Datas.java:23
↓ 5 callersMethodgetNextFileNumber
()
lsm/src/lsm/internal/VersionSetImpl.java:386
↓ 5 callersMethodgetRange
获取所有文件的最终大小范围 @param inputLists @return 最小值和最大值
lsm/src/lsm/internal/VersionSetImpl.java:334
↓ 5 callersMethodgetVarWithLenPrefix
(ByteBuf src)
lsm/src/lsm/base/ByteBufUtils.java:71
↓ 5 callersMethodputVarWithLenPrefix
(ByteBuf dst, ByteBuf data)
lsm/src/lsm/base/ByteBufUtils.java:61
↓ 5 callersMethodsetComparatorName
(String comparatorName)
lsm/src/lsm/internal/VersionEdit.java:243
↓ 5 callersMethodsetLogNumber
(Long logNumber)
lsm/src/lsm/internal/VersionEdit.java:246
↓ 5 callersMethodtoString
()
rpc/src/rpc/data/IRequest.java:54
↓ 4 callersMethodcompare
(FileMetaData left, FileMetaData right)
lsm/src/lsm/internal/LevelImpl.java:21
↓ 4 callersMethodgetCurrent
获取当前版本 @return
lsm/src/lsm/VersionSet.java:75
↓ 4 callersMethodgetCurrent
()
lsm/src/lsm/internal/VersionSetImpl.java:391
↓ 4 callersMethodgetEdit
(VersionSet versionSet, long logNumber)
example/src/lsm/VersionTest.java:62
↓ 4 callersMethodgetFileSize
获取当前文件实际大小 @return @throws IOException
lsm/src/lsm/SSTableBuilder.java:41
↓ 4 callersMethodgetHandle
handle指的是位置和大小信息 @param offset 偏置,即起始位置 @param size 大小 @return handle的字节数据
lsm/src/lsm/internal/SSTableBuilderImpl.java:185
↓ 4 callersMethodgetHost
@param @return
rpc/src/rpc/cluster/Cluster.java:13
↓ 4 callersMethodgetLevel
获取需要compact的低一层 @return
lsm/src/lsm/base/Compaction.java:88
↓ 4 callersMethodgetOverlappingInputs
寻找第level层和指定范围有重叠的全部文件信息 @param level 层数 @param smallest 最小值 @param largest 最大值 @return 所有重叠文件
lsm/src/lsm/internal/VersionSetImpl.java:365
↓ 4 callersMethodgetPort
()
rpc/src/rpc/model/RegistryBean.java:12
↓ 4 callersMethodgetProviderPath
形如: /appKey/service/providers/IP @param url @return
rpc/src/rpc/impl/ZookeeperRegistry.java:298
↓ 4 callersMethodhasNext
()
lsm/src/lsm/internal/SSTableImpl.java:180
↓ 4 callersMethodlogAndApply
(VersionEdit edit)
lsm/src/lsm/internal/VersionSetImpl.java:198
↓ 4 callersMethodmakeFileName
(long number, String suffix)
lsm/src/lsm/base/FileUtils.java:75
↓ 4 callersMethodnewSSTableFile
新建sstable文件 @param databaseDir @param fileNumber @return @throws IOException
lsm/src/lsm/base/FileUtils.java:20
↓ 4 callersMethodnext
()
lsm/src/lsm/internal/SSTableImpl.java:190
↓ 4 callersMethodpeek
取出当前指针数据但是不移动指针 @return 当前指针位置数据
lsm/src/lsm/SeekingIterator.java:19
↓ 4 callersMethodrelease
减少一次引用计数
lsm/src/lsm/Version.java:46
↓ 4 callersMethodseek
指针移动到第一个 >= key 的位置 @param key 键 @return
lsm/src/lsm/SeekingIterator.java:26
↓ 4 callersMethodsetLastSequenceNumber
(Long lastSequenceNumber)
lsm/src/lsm/internal/VersionEdit.java:252
↓ 4 callersMethodsetNextFileNumber
(Long nextFileNumber)
lsm/src/lsm/internal/VersionEdit.java:249
↓ 3 callersMethodaddFile
加入文件 @param file
lsm/src/lsm/Level.java:32
↓ 3 callersMethodappendPath
(String path)
rpc/src/rpc/URL.java:54
↓ 3 callersMethodappendVersion
将version指定为current,存入version列表 @param version
lsm/src/lsm/internal/VersionSetImpl.java:288
↓ 3 callersMethodbuild
根据apply的edit信息,产生一个version对象 @return
lsm/src/lsm/VersionBuilder.java:20
↓ 3 callersMethodconnect
连接获取客户端 @param clientURL @return
rpc/src/rpc/Exchanger.java:15
↓ 3 callersMethodfiles
某层中的文件总数 @param level 层编号 @return 文件数目
lsm/src/lsm/Version.java:88
↓ 3 callersMethodgetLastSequenceNumber
()
lsm/src/lsm/internal/VersionEdit.java:264
↓ 3 callersMethodgetLevelInputs
获取低一层需要compact的文件 @return
lsm/src/lsm/base/Compaction.java:72
↓ 3 callersMethodgetMethod
()
rpc/src/rpc/data/IRequest.java:46
↓ 3 callersMethodgetNextElement
核心实现,通过level1迭代器获取level2迭代器,进而获取实际k-v数据 @return
lsm/src/lsm/internal/SSTableImpl.java:279
↓ 3 callersMethodgetNextFileNumber
获取下一个文件编号 @return
lsm/src/lsm/VersionSet.java:70
↓ 3 callersMethodgetNextFileNumber
()
lsm/src/lsm/internal/VersionEdit.java:261
↓ 3 callersMethodgetResult
获取异步数据 @return
rpc/src/rpc/impl/AsyncResult.java:49
↓ 3 callersMethodgetThread
()
lsm/src/lsm/internal/EngineImpl.java:748
↓ 3 callersMethodgetUrl
获取本节点的url @return
rpc/src/rpc/Node.java:8
↓ 3 callersMethodgetValue
()
lsm/src/lsm/internal/EngineImpl.java:733
↓ 3 callersMethodgetValueBytes
()
lsm/src/lsm/base/LookupResult.java:35
↓ 3 callersMethodgetValues
()
example/src/lsm/Datas.java:37
↓ 3 callersMethodhost
(String host)
rpc/src/rpc/URL.java:32
↓ 3 callersMethodisDone
()
lsm/src/lsm/internal/EngineImpl.java:745
↓ 3 callersMethoditerator
()
lsm/src/lsm/internal/SSTableImpl.java:138
↓ 3 callersMethodlogAndApply
记录和应用一个edit,来产生一个新的version @param edit @throws IOException
lsm/src/lsm/VersionSet.java:36
↓ 3 callersMethodmaybeCompaction
尝试触发compact,是异步操作
lsm/src/lsm/internal/EngineImpl.java:306
next →1–100 of 669, ranked by callers