Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cenwenchu/beatles
/ functions
Functions
1,163 in github.com/cenwenchu/beatles
⨍
Functions
1,163
◇
Types & classes
171
↓ 599 callers
Method
get
从配置中根据名称获得属性内容 @param propName
src/java/com/taobao/top/analysis/config/IConfig.java:28
↓ 272 callers
Method
add
Add the specified binary to the bloom filter. @param buf data to be added to the bloom
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:29
↓ 137 callers
Method
size
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:228
↓ 100 callers
Method
toString
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:158
↓ 96 callers
Method
getJobName
()
src/java/com/taobao/top/analysis/node/job/Job.java:448
↓ 88 callers
Method
equals
(Object e)
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:39
↓ 67 callers
Method
toString
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:239
↓ 65 callers
Method
write
(DataOutput out)
src/java/com/taobao/top/analysis/util/bloom/Writable.java:18
↓ 55 callers
Method
getValue
@return the value
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:23
↓ 42 callers
Method
remove
(Object o)
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:223
↓ 40 callers
Method
getTaskId
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:186
↓ 39 callers
Method
toString
()
src/java/com/taobao/top/analysis/statistics/reduce/IReducer.java:28
↓ 38 callers
Method
getKey
()
src/java/com/taobao/top/analysis/statistics/data/Alias.java:28
↓ 35 callers
Method
getSequence
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:39
↓ 33 callers
Method
getInput
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:198
↓ 31 callers
Method
getChannel
(String address)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:117
↓ 30 callers
Method
clear
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:79
↓ 28 callers
Method
getJobResult
()
src/java/com/taobao/top/analysis/node/job/Job.java:420
↓ 26 callers
Method
getName
()
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:652
↓ 24 callers
Method
getStatisticsRule
()
src/java/com/taobao/top/analysis/node/job/Job.java:468
↓ 24 callers
Method
set
Set the bit at the specified index to 1. @param pos index of bit
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:212
↓ 23 callers
Method
getReportEntrys
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:101
↓ 22 callers
Method
getInstance
根据接口定义获取实际的接口实现实例 @param <I> @param interfaceDefinition @param classLoader @param className @param needCache @return
src/java/com/taobao/top/analysis/util/ReportUtil.java:420
↓ 22 callers
Method
getMonitorDocRoot
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:364
↓ 22 callers
Method
poll
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:270
↓ 21 callers
Method
getJobConfig
()
src/java/com/taobao/top/analysis/node/job/Job.java:458
↓ 20 callers
Method
drawLine
绘制折线图 @param name @param xName @param yName @param outputFileName @param multiLineData
src/java/com/taobao/top/analysis/util/ChartUtil.java:199
↓ 20 callers
Method
getEntryPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:132
↓ 20 callers
Method
getJobs
()
src/java/com/taobao/top/analysis/node/IJobManager.java:93
↓ 20 callers
Method
getMultiLineData
@param snapshot @param type @return
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:400
↓ 20 callers
Method
getTaskIds
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:134
↓ 19 callers
Method
addInputAdaptor
(IInputAdaptor inputAdaptor)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:84
↓ 19 callers
Method
getId
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:85
↓ 19 callers
Method
getUrl
@return the url
src/java/com/taobao/top/analysis/node/job/JobTask.java:235
↓ 18 callers
Method
contains
Check if the specified key is contained in the bloom filter. @param buf data to check for existence of @return true if matched by bloom, false if not
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:45
↓ 18 callers
Method
setConfig
设置组件的配置 @param config
src/java/com/taobao/top/analysis/node/IComponent.java:38
↓ 16 callers
Method
callback
(int code,long len)
src/java/com/taobao/top/analysis/HttpAgentNode.java:108
↓ 16 callers
Method
getJobTasks
请求任务 @param 请求任务参数 @return
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:29
↓ 15 callers
Method
getReportPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:140
↓ 15 callers
Method
init
初始化节点,申请资源
src/java/com/taobao/top/analysis/node/IComponent.java:21
↓ 14 callers
Method
load
从外部配置文件载入 @param properties
src/java/com/taobao/top/analysis/config/IConfig.java:22
↓ 14 callers
Method
offer
(E e)
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:249
↓ 14 callers
Method
stopNode
停止节点
src/java/com/taobao/top/analysis/node/INode.java:46
↓ 13 callers
Method
getId
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:140
↓ 13 callers
Method
getResults
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:150
↓ 13 callers
Method
getSlaveSide
()
src/java/com/taobao/top/analysis/node/connect/MemTunnel.java:33
↓ 13 callers
Method
releaseResource
节点停止的时候释放资源
src/java/com/taobao/top/analysis/node/IComponent.java:26
↓ 12 callers
Method
getEpoch
()
src/java/com/taobao/top/analysis/node/job/Job.java:263
↓ 12 callers
Method
getJobEpoch
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:128
↓ 11 callers
Method
clear
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:205
↓ 11 callers
Method
getConfig
获取组件的配置 @return
src/java/com/taobao/top/analysis/node/IComponent.java:32
↓ 11 callers
Method
getIp
()
src/java/com/taobao/top/analysis/util/ReportUtil.java:69
↓ 11 callers
Method
getJobTasks
()
src/java/com/taobao/top/analysis/node/event/GetTaskResponseEvent.java:35
↓ 11 callers
Method
getSaveTmpResultToFile
()
src/java/com/taobao/top/analysis/config/JobConfig.java:254
↓ 11 callers
Method
getTrunkLock
()
src/java/com/taobao/top/analysis/node/job/Job.java:289
↓ 10 callers
Method
getAliasPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:148
↓ 10 callers
Method
getGroupId
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:122
↓ 10 callers
Method
getJobName
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:136
↓ 10 callers
Method
getKey
()
src/java/com/taobao/top/analysis/util/ReportUtil.java:1490
↓ 10 callers
Method
getMasterName
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:227
↓ 10 callers
Method
getZkServer
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:109
↓ 10 callers
Method
start
开启节点 并开启配置扫描线程
src/java/com/taobao/top/analysis/TopAnalysisNode.java:229
↓ 9 callers
Method
getCursorMap
@return the cursorMap
src/java/com/taobao/top/analysis/node/job/Job.java:724
↓ 9 callers
Method
getDispatchMaster
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:408
↓ 9 callers
Method
getFile
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:93
↓ 9 callers
Method
getJobTaskResult
()
src/java/com/taobao/top/analysis/node/event/SendResultsRequestEvent.java:31
↓ 9 callers
Method
getMasterPort
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:205
↓ 9 callers
Method
getMergedTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:497
↓ 9 callers
Method
isEmpty
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:218
↓ 9 callers
Method
setJobResult
(Map<String, Map<String, Object>> jobResult)
src/java/com/taobao/top/analysis/node/job/Job.java:424
↓ 9 callers
Method
sholdBlock
()
src/java/com/taobao/top/analysis/util/Threshold.java:31
↓ 8 callers
Method
doAnalysis
(JobTask jobTask)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:116
↓ 8 callers
Method
export
内部协议导出对象 @param 结果对象 @param 文件名 @param 是否需要压缩 @param 是否需要覆盖原来的文件
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:805
↓ 8 callers
Method
generateKey
创建key @param 报表entry定义 @param 日志切割后的字符串数组 @param 别名定义 @param tempMapParam 有些情况下entry的mapClass对应的mapParams需要临时被修改掉, 但是涉及到entry的并
src/java/com/taobao/top/analysis/node/map/IReportMap.java:33
↓ 8 callers
Method
getEventCode
()
src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:57
↓ 8 callers
Method
getEventCreateTime
获得创建时间,long类型,毫秒 @return
src/java/com/taobao/top/analysis/util/TimeOutEvent.java:19
↓ 8 callers
Method
getMapParams
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:168
↓ 8 callers
Method
getTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:481
↓ 8 callers
Method
isSuccess
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:36
↓ 7 callers
Method
buildMaster
(String configfile)
src/java.test/com/taobao/top/analysis/node/component/MasterSlaveIntegrationTest_SocketVersion.java:36
↓ 7 callers
Method
echoSendJobTaskResults
响应发送任务结果的请求 @param 返回结果
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:32
↓ 7 callers
Method
getEventCode
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:47
↓ 7 callers
Method
getName
()
src/java/com/taobao/top/analysis/statistics/data/Alias.java:20
↓ 7 callers
Method
getOutput
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:204
↓ 7 callers
Method
getReport2Master
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:92
↓ 7 callers
Method
getReportConfigs
()
src/java/com/taobao/top/analysis/config/JobConfig.java:134
↓ 7 callers
Method
getUnDoJobTasks
获取没有完成的任务 @param 个数
src/java/com/taobao/top/analysis/node/IJobManager.java:36
↓ 7 callers
Method
getcIndex
()
src/java/com/taobao/top/analysis/statistics/data/ObjectColumn.java:28
↓ 7 callers
Method
init
()
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:65
↓ 7 callers
Method
init
()
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:79
↓ 7 callers
Method
isMerged
()
src/java/com/taobao/top/analysis/node/job/Job.java:428
↓ 7 callers
Method
releaseResource
()
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:69
↓ 7 callers
Method
sendJobTaskResults
发送分析后的结果 @param 分析后的结果 @param 支持多个master分担处理结果 @return
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:37
↓ 7 callers
Method
setRequestJobCount
(int requestJobCount)
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:51
↓ 6 callers
Method
addEvent
向Node发送消息 @param event @return
src/java/com/taobao/top/analysis/node/INode.java:30
↓ 6 callers
Method
build
()
src/java/com/taobao/top/analysis/node/component/MixJobBuilder.java:70
↓ 6 callers
Method
getCalculator
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:180
↓ 6 callers
Method
getData
@param context
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:127
↓ 6 callers
Method
getJobTaskResultsQueuePool
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:1028
↓ 6 callers
Method
getKeys
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:198
next →
1–100 of 1,163, ranked by callers