MCPcopy Create free account

hub / github.com/cenwenchu/beatles / functions

Functions1,163 in github.com/cenwenchu/beatles

↓ 599 callersMethodget
从配置中根据名称获得属性内容 @param propName
src/java/com/taobao/top/analysis/config/IConfig.java:28
↓ 272 callersMethodadd
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 callersMethodsize
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:228
↓ 100 callersMethodtoString
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:158
↓ 96 callersMethodgetJobName
()
src/java/com/taobao/top/analysis/node/job/Job.java:448
↓ 88 callersMethodequals
(Object e)
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:39
↓ 67 callersMethodtoString
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:239
↓ 65 callersMethodwrite
(DataOutput out)
src/java/com/taobao/top/analysis/util/bloom/Writable.java:18
↓ 55 callersMethodgetValue
@return the value
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:23
↓ 42 callersMethodremove
(Object o)
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:223
↓ 40 callersMethodgetTaskId
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:186
↓ 39 callersMethodtoString
()
src/java/com/taobao/top/analysis/statistics/reduce/IReducer.java:28
↓ 38 callersMethodgetKey
()
src/java/com/taobao/top/analysis/statistics/data/Alias.java:28
↓ 35 callersMethodgetSequence
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:39
↓ 33 callersMethodgetInput
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:198
↓ 31 callersMethodgetChannel
(String address)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:117
↓ 30 callersMethodclear
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:79
↓ 28 callersMethodgetJobResult
()
src/java/com/taobao/top/analysis/node/job/Job.java:420
↓ 26 callersMethodgetName
()
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:652
↓ 24 callersMethodgetStatisticsRule
()
src/java/com/taobao/top/analysis/node/job/Job.java:468
↓ 24 callersMethodset
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 callersMethodgetReportEntrys
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:101
↓ 22 callersMethodgetInstance
根据接口定义获取实际的接口实现实例 @param <I> @param interfaceDefinition @param classLoader @param className @param needCache @return
src/java/com/taobao/top/analysis/util/ReportUtil.java:420
↓ 22 callersMethodgetMonitorDocRoot
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:364
↓ 22 callersMethodpoll
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:270
↓ 21 callersMethodgetJobConfig
()
src/java/com/taobao/top/analysis/node/job/Job.java:458
↓ 20 callersMethoddrawLine
绘制折线图 @param name @param xName @param yName @param outputFileName @param multiLineData
src/java/com/taobao/top/analysis/util/ChartUtil.java:199
↓ 20 callersMethodgetEntryPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:132
↓ 20 callersMethodgetJobs
()
src/java/com/taobao/top/analysis/node/IJobManager.java:93
↓ 20 callersMethodgetMultiLineData
@param snapshot @param type @return
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:400
↓ 20 callersMethodgetTaskIds
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:134
↓ 19 callersMethodaddInputAdaptor
(IInputAdaptor inputAdaptor)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:84
↓ 19 callersMethodgetId
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:85
↓ 19 callersMethodgetUrl
@return the url
src/java/com/taobao/top/analysis/node/job/JobTask.java:235
↓ 18 callersMethodcontains
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 callersMethodsetConfig
设置组件的配置 @param config
src/java/com/taobao/top/analysis/node/IComponent.java:38
↓ 16 callersMethodcallback
(int code,long len)
src/java/com/taobao/top/analysis/HttpAgentNode.java:108
↓ 16 callersMethodgetJobTasks
请求任务 @param 请求任务参数 @return
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:29
↓ 15 callersMethodgetReportPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:140
↓ 15 callersMethodinit
初始化节点,申请资源
src/java/com/taobao/top/analysis/node/IComponent.java:21
↓ 14 callersMethodload
从外部配置文件载入 @param properties
src/java/com/taobao/top/analysis/config/IConfig.java:22
↓ 14 callersMethodoffer
(E e)
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:249
↓ 14 callersMethodstopNode
停止节点
src/java/com/taobao/top/analysis/node/INode.java:46
↓ 13 callersMethodgetId
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:140
↓ 13 callersMethodgetResults
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:150
↓ 13 callersMethodgetSlaveSide
()
src/java/com/taobao/top/analysis/node/connect/MemTunnel.java:33
↓ 13 callersMethodreleaseResource
节点停止的时候释放资源
src/java/com/taobao/top/analysis/node/IComponent.java:26
↓ 12 callersMethodgetEpoch
()
src/java/com/taobao/top/analysis/node/job/Job.java:263
↓ 12 callersMethodgetJobEpoch
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:128
↓ 11 callersMethodclear
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:205
↓ 11 callersMethodgetConfig
获取组件的配置 @return
src/java/com/taobao/top/analysis/node/IComponent.java:32
↓ 11 callersMethodgetIp
()
src/java/com/taobao/top/analysis/util/ReportUtil.java:69
↓ 11 callersMethodgetJobTasks
()
src/java/com/taobao/top/analysis/node/event/GetTaskResponseEvent.java:35
↓ 11 callersMethodgetSaveTmpResultToFile
()
src/java/com/taobao/top/analysis/config/JobConfig.java:254
↓ 11 callersMethodgetTrunkLock
()
src/java/com/taobao/top/analysis/node/job/Job.java:289
↓ 10 callersMethodgetAliasPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:148
↓ 10 callersMethodgetGroupId
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:122
↓ 10 callersMethodgetJobName
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:136
↓ 10 callersMethodgetKey
()
src/java/com/taobao/top/analysis/util/ReportUtil.java:1490
↓ 10 callersMethodgetMasterName
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:227
↓ 10 callersMethodgetZkServer
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:109
↓ 10 callersMethodstart
开启节点 并开启配置扫描线程
src/java/com/taobao/top/analysis/TopAnalysisNode.java:229
↓ 9 callersMethodgetCursorMap
@return the cursorMap
src/java/com/taobao/top/analysis/node/job/Job.java:724
↓ 9 callersMethodgetDispatchMaster
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:408
↓ 9 callersMethodgetFile
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:93
↓ 9 callersMethodgetJobTaskResult
()
src/java/com/taobao/top/analysis/node/event/SendResultsRequestEvent.java:31
↓ 9 callersMethodgetMasterPort
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:205
↓ 9 callersMethodgetMergedTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:497
↓ 9 callersMethodisEmpty
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:218
↓ 9 callersMethodsetJobResult
(Map<String, Map<String, Object>> jobResult)
src/java/com/taobao/top/analysis/node/job/Job.java:424
↓ 9 callersMethodsholdBlock
()
src/java/com/taobao/top/analysis/util/Threshold.java:31
↓ 8 callersMethoddoAnalysis
(JobTask jobTask)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:116
↓ 8 callersMethodexport
内部协议导出对象 @param 结果对象 @param 文件名 @param 是否需要压缩 @param 是否需要覆盖原来的文件
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:805
↓ 8 callersMethodgenerateKey
创建key @param 报表entry定义 @param 日志切割后的字符串数组 @param 别名定义 @param tempMapParam 有些情况下entry的mapClass对应的mapParams需要临时被修改掉, 但是涉及到entry的并
src/java/com/taobao/top/analysis/node/map/IReportMap.java:33
↓ 8 callersMethodgetEventCode
()
src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:57
↓ 8 callersMethodgetEventCreateTime
获得创建时间,long类型,毫秒 @return
src/java/com/taobao/top/analysis/util/TimeOutEvent.java:19
↓ 8 callersMethodgetMapParams
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:168
↓ 8 callersMethodgetTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:481
↓ 8 callersMethodisSuccess
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:36
↓ 7 callersMethodbuildMaster
(String configfile)
src/java.test/com/taobao/top/analysis/node/component/MasterSlaveIntegrationTest_SocketVersion.java:36
↓ 7 callersMethodechoSendJobTaskResults
响应发送任务结果的请求 @param 返回结果
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:32
↓ 7 callersMethodgetEventCode
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:47
↓ 7 callersMethodgetName
()
src/java/com/taobao/top/analysis/statistics/data/Alias.java:20
↓ 7 callersMethodgetOutput
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:204
↓ 7 callersMethodgetReport2Master
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:92
↓ 7 callersMethodgetReportConfigs
()
src/java/com/taobao/top/analysis/config/JobConfig.java:134
↓ 7 callersMethodgetUnDoJobTasks
获取没有完成的任务 @param 个数
src/java/com/taobao/top/analysis/node/IJobManager.java:36
↓ 7 callersMethodgetcIndex
()
src/java/com/taobao/top/analysis/statistics/data/ObjectColumn.java:28
↓ 7 callersMethodinit
()
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:65
↓ 7 callersMethodinit
()
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:79
↓ 7 callersMethodisMerged
()
src/java/com/taobao/top/analysis/node/job/Job.java:428
↓ 7 callersMethodreleaseResource
()
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:69
↓ 7 callersMethodsendJobTaskResults
发送分析后的结果 @param 分析后的结果 @param 支持多个master分担处理结果 @return
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:37
↓ 7 callersMethodsetRequestJobCount
(int requestJobCount)
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:51
↓ 6 callersMethodaddEvent
向Node发送消息 @param event @return
src/java/com/taobao/top/analysis/node/INode.java:30
↓ 6 callersMethodbuild
()
src/java/com/taobao/top/analysis/node/component/MixJobBuilder.java:70
↓ 6 callersMethodgetCalculator
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:180
↓ 6 callersMethodgetData
@param context
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:127
↓ 6 callersMethodgetJobTaskResultsQueuePool
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:1028
↓ 6 callersMethodgetKeys
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:198
next →1–100 of 1,163, ranked by callers