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
↓ 2 callers
Method
setSlavePulledTaskCount
(long slavePulledTaskCount)
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:201
↓ 2 callers
Method
setStartTime
(long startTime)
src/java/com/taobao/top/analysis/node/job/JobTask.java:171
↓ 2 callers
Method
setSubKeys
(List<ObjectColumn> subKeys)
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:207
↓ 2 callers
Method
setSystemLoadAverage
(Double systemLoadAverage)
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:162
↓ 2 callers
Method
setTotalLine
(long totalLine)
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:58
↓ 2 callers
Method
setTunnel
(MemTunnel tunnel)
src/java/com/taobao/top/analysis/node/connect/MemMasterConnector.java:53
↓ 2 callers
Method
setValue
@param value the value to set
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:30
↓ 2 callers
Method
setVersion
(long version)
src/java/com/taobao/top/analysis/statistics/data/Rule.java:160
↓ 2 callers
Method
suspendNode
()
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:70
↓ 2 callers
Method
toString
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:189
↓ 2 callers
Method
transformVars
根据别名定义来转换报表模型中定义的key,直接转换为实际的列号 @param keys @param aliasPool
src/java/com/taobao/top/analysis/util/ReportUtil.java:363
↓ 2 callers
Method
updateCache
更新缓存数据, 使每个slave的数据保持在最新的100个 @param info
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:153
↓ 1 callers
Method
addAllToConfig
将外部的配置加入到配置中 @param 外部配置
src/java/com/taobao/top/analysis/config/IConfig.java:16
↓ 1 callers
Method
addFileInputStream
(java.io.FileInputStream is)
src/java/com/taobao/top/analysis/HttpAgentNode.java:637
↓ 1 callers
Method
addFileLen
(int fileLen)
src/java/com/taobao/top/analysis/HttpAgentNode.java:648
↓ 1 callers
Method
addFileName
(byte[] fileName)
src/java/com/taobao/top/analysis/HttpAgentNode.java:630
↓ 1 callers
Method
addFnLen
(int fnLen)
src/java/com/taobao/top/analysis/HttpAgentNode.java:654
↓ 1 callers
Method
addJobsToPool
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:680
↓ 1 callers
Method
addOutputAdaptor
(IOutputAdaptor outputAdaptor)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:32
↓ 1 callers
Method
addTaskExecuteInfos
(Map<String,JobTaskExecuteInfo> taskExecuteInfos)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:128
↓ 1 callers
Method
addTaskIds
(List<String> taskIds)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:123
↓ 1 callers
Method
analysis
(InputStream in,JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:178
↓ 1 callers
Method
blockToResetJob
(long waittime)
src/java/com/taobao/top/analysis/node/job/Job.java:213
↓ 1 callers
Method
build
(String path)
src/java/com/taobao/top/analysis/node/job/JobResource.java:41
↓ 1 callers
Method
buildMaster
初始化master
src/java/com/taobao/top/analysis/TopAnalysisNode.java:255
↓ 1 callers
Method
buildRule
编译分析规则模型 @param configs @param rule @throws IOException @throws AnalysisException
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:317
↓ 1 callers
Method
buildSlave
初始化slave
src/java/com/taobao/top/analysis/TopAnalysisNode.java:284
↓ 1 callers
Method
buildTasks
(Job job)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1020
↓ 1 callers
Method
calculator
(Object[] content)
src/java/com/taobao/top/analysis/statistics/data/ICalculator.java:7
↓ 1 callers
Method
changeMaster
运行期可以切换主master @param master
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:48
↓ 1 callers
Method
checkConfigModified
()
src/java/com/taobao/top/analysis/TopAnalysisNode.java:320
↓ 1 callers
Method
checkJobTimeOut
()
src/java/com/taobao/top/analysis/node/job/Job.java:308
↓ 1 callers
Method
checkKeyCondition
返回是否符合条件 @param operator @param conditionKey @param conditionValue @param contents @return
src/java/com/taobao/top/analysis/statistics/data/impl/SimpleCondition.java:179
↓ 1 callers
Method
checkTaskStatus
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:938
↓ 1 callers
Method
clean
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:59
↓ 1 callers
Method
cleanPeriodData
(Map<String, Map<String, Object>> result, Map<String, ReportEntry> entryPool)
src/java/com/taobao/top/analysis/util/ReportUtil.java:689
↓ 1 callers
Method
clearJobData
清除掉某一个job在内存的数据 @param 任务名称
src/java/com/taobao/top/analysis/node/IJobManager.java:66
↓ 1 callers
Method
clone
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:213
↓ 1 callers
Method
cloneResultFromTrunk
将主干上属于distinct count部分数据保留下来不输出,其他内容都输出且清空 @return
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:621
↓ 1 callers
Method
compareTo
(MemberWeight o)
src/java/com/taobao/top/analysis/util/ReportUtil.java:1513
↓ 1 callers
Method
convertStringToMap
将string转为map简单实现 @param string @param recordSplit @param mapSplit @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:322
↓ 1 callers
Method
createDCEntryValue
(ReportEntry entry)
src/java/com/taobao/top/analysis/statistics/reduce/group/DistinctCountFunction.java:86
↓ 1 callers
Method
createGroupNodesIfNotExist
(ZooKeeper zk,String groupId)
src/java.test/com/taobao/top/analysis/TestZookeeper.java:76
↓ 1 callers
Method
createPath
循环创建路径中不存在的节点 @param zk @param path @throws InterruptedException @throws KeeperException
src/java/com/taobao/top/analysis/util/ZKUtil.java:150
↓ 1 callers
Method
createReportFile
(String reportFile,Report report,Map<String, Map<String, Object>> entryResultPool,List<String> reports,Cou
src/java/com/taobao/top/analysis/node/operation/CreateReportOperation.java:60
↓ 1 callers
Method
createTimeStampFile
(String dir)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:349
↓ 1 callers
Method
deleteData
()
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:336
↓ 1 callers
Method
doExport
(JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:37
↓ 1 callers
Method
draw
(Map<String, List<SlaveMonitorInfo>> snapshot)
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:204
↓ 1 callers
Method
echoSendMonitorInfo
(String sequence, MasterMonitorInfo info, Object channel)
src/java/com/taobao/top/analysis/node/component/MasterNode.java:202
↓ 1 callers
Method
echoSendMonitorInfo
响应发送监控信息请求 @param event
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:38
↓ 1 callers
Method
equals
(Object obj)
src/java/com/taobao/top/analysis/config/AbstractConfig.java:255
↓ 1 callers
Method
executedTask
任务执行统计 @param count
src/java/com/taobao/top/analysis/node/component/SlaveMonitor.java:101
↓ 1 callers
Method
exportEntryData
导出分析器某一个job主干的中间分析数据 @param job
src/java/com/taobao/top/analysis/node/IJobExporter.java:43
↓ 1 callers
Method
exportEntryData
(Job job)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:377
↓ 1 callers
Method
exportJobData
导出内存任务数据到磁盘 @param 需要导出的任务
src/java/com/taobao/top/analysis/node/IJobManager.java:48
↓ 1 callers
Method
exportJobMonitorInfo
导出Job级别的监控信息
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:546
↓ 1 callers
Method
exportJobTaskMonitorInfo
()
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:613
↓ 1 callers
Method
exportOrCleanTrunk
在导出数据以后,判断是否需要清空主干,是否需要导出主干 @param job
src/java/com/taobao/top/analysis/node/component/JobManager.java:864
↓ 1 callers
Method
exportSystemMonitorInfo
导出系统级别的监控信息
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:495
↓ 1 callers
Method
filter
生成了value之后用来过滤生成的value的 @param value @return
src/java/com/taobao/top/analysis/statistics/data/IFilter.java:16
↓ 1 callers
Method
formatValue
格式化结果,很消耗... @param formatStack @param value @return
src/java/com/taobao/top/analysis/util/ReportUtil.java:525
↓ 1 callers
Method
generateValue
(ReportEntry entry,Object[] contents, JobTask jobtask)
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:45
↓ 1 callers
Method
get
Check if bit at specified index is 1. @param pos index of bit @return true if bit at specified index is 1, false if 0.
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:227
↓ 1 callers
Method
getAveragePullTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:165
↓ 1 callers
Method
getAveragePulledTaskCount
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:173
↓ 1 callers
Method
getAverageTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:181
↓ 1 callers
Method
getBloomFilter
()
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:27
↓ 1 callers
Method
getByteSize
Size of the bloom, in bytes @return
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:73
↓ 1 callers
Method
getConfigFromProps
(String jobName,JobConfig jobConfig,Properties prop)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:290
↓ 1 callers
Method
getDate
()
src/java/com/taobao/top/analysis/node/io/HubInputAdaptor.java:144
↓ 1 callers
Method
getEfficiency
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:94
↓ 1 callers
Method
getFile
()
src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:42
↓ 1 callers
Method
getFileBegin
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:137
↓ 1 callers
Method
getFileLen
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:645
↓ 1 callers
Method
getFileLength
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:140
↓ 1 callers
Method
getFnLen
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:651
↓ 1 callers
Method
getFormatStack
()
src/java/com/taobao/top/analysis/statistics/data/impl/SimpleFilter.java:41
↓ 1 callers
Method
getFunction
(String value)
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunctionFactory.java:21
↓ 1 callers
Method
getGroupConfigZKPath
获得某一个group的config节点 @param groupId @return
src/java/com/taobao/top/analysis/util/ZKUtil.java:92
↓ 1 callers
Method
getGroupId
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:165
↓ 1 callers
Method
getHttpContext
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:170
↓ 1 callers
Method
getHttpPort
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:163
↓ 1 callers
Method
getInputFormJob
(JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/io/IInputAdaptor.java:21
↓ 1 callers
Method
getInputFormJob
(JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/io/HdfsInputAdaptor.java:31
↓ 1 callers
Method
getJobBuilder
()
src/java/com/taobao/top/analysis/node/IJobManager.java:81
↓ 1 callers
Method
getJobExportTime
()
src/java/com/taobao/top/analysis/node/job/Job.java:412
↓ 1 callers
Method
getJobName
@return the jobName
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:185
↓ 1 callers
Method
getJobSourceTimeStamp
@return the jobSourceTimeStamp
src/java/com/taobao/top/analysis/node/job/JobTask.java:264
↓ 1 callers
Method
getJvmFreeMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:110
↓ 1 callers
Method
getJvmMaxMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:118
↓ 1 callers
Method
getJvmPeakThreadCount
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:134
↓ 1 callers
Method
getJvmThreadCount
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:126
↓ 1 callers
Method
getJvmTotalMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:102
↓ 1 callers
Method
getLastExportTime
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:117
↓ 1 callers
Method
getManifestAttr
获取MANIFEST.MF文件中的属性 @param attr @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:53
↓ 1 callers
Method
getManifestBuildDate
获取MANIFEST.MF文件的创建时间作为打包时间 @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:71
↓ 1 callers
Method
getMasterConnector
()
src/java/com/taobao/top/analysis/node/component/MasterNode.java:73
↓ 1 callers
Method
getMasterPort
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:238
↓ 1 callers
Method
getMasters
@return the masters
src/java/com/taobao/top/analysis/statistics/data/Rule.java:167
← previous
next →
401–500 of 1,163, ranked by callers