MCPcopy Create free account

hub / github.com/cenwenchu/beatles / functions

Functions1,163 in github.com/cenwenchu/beatles

↓ 2 callersMethodsetSlavePulledTaskCount
(long slavePulledTaskCount)
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:201
↓ 2 callersMethodsetStartTime
(long startTime)
src/java/com/taobao/top/analysis/node/job/JobTask.java:171
↓ 2 callersMethodsetSubKeys
(List<ObjectColumn> subKeys)
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:207
↓ 2 callersMethodsetSystemLoadAverage
(Double systemLoadAverage)
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:162
↓ 2 callersMethodsetTotalLine
(long totalLine)
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:58
↓ 2 callersMethodsetTunnel
(MemTunnel tunnel)
src/java/com/taobao/top/analysis/node/connect/MemMasterConnector.java:53
↓ 2 callersMethodsetValue
@param value the value to set
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:30
↓ 2 callersMethodsetVersion
(long version)
src/java/com/taobao/top/analysis/statistics/data/Rule.java:160
↓ 2 callersMethodsuspendNode
()
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:70
↓ 2 callersMethodtoString
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:189
↓ 2 callersMethodtransformVars
根据别名定义来转换报表模型中定义的key,直接转换为实际的列号 @param keys @param aliasPool
src/java/com/taobao/top/analysis/util/ReportUtil.java:363
↓ 2 callersMethodupdateCache
更新缓存数据, 使每个slave的数据保持在最新的100个 @param info
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:153
↓ 1 callersMethodaddAllToConfig
将外部的配置加入到配置中 @param 外部配置
src/java/com/taobao/top/analysis/config/IConfig.java:16
↓ 1 callersMethodaddFileInputStream
(java.io.FileInputStream is)
src/java/com/taobao/top/analysis/HttpAgentNode.java:637
↓ 1 callersMethodaddFileLen
(int fileLen)
src/java/com/taobao/top/analysis/HttpAgentNode.java:648
↓ 1 callersMethodaddFileName
(byte[] fileName)
src/java/com/taobao/top/analysis/HttpAgentNode.java:630
↓ 1 callersMethodaddFnLen
(int fnLen)
src/java/com/taobao/top/analysis/HttpAgentNode.java:654
↓ 1 callersMethodaddJobsToPool
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:680
↓ 1 callersMethodaddOutputAdaptor
(IOutputAdaptor outputAdaptor)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:32
↓ 1 callersMethodaddTaskExecuteInfos
(Map<String,JobTaskExecuteInfo> taskExecuteInfos)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:128
↓ 1 callersMethodaddTaskIds
(List<String> taskIds)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:123
↓ 1 callersMethodanalysis
(InputStream in,JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:178
↓ 1 callersMethodblockToResetJob
(long waittime)
src/java/com/taobao/top/analysis/node/job/Job.java:213
↓ 1 callersMethodbuild
(String path)
src/java/com/taobao/top/analysis/node/job/JobResource.java:41
↓ 1 callersMethodbuildMaster
初始化master
src/java/com/taobao/top/analysis/TopAnalysisNode.java:255
↓ 1 callersMethodbuildRule
编译分析规则模型 @param configs @param rule @throws IOException @throws AnalysisException
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:317
↓ 1 callersMethodbuildSlave
初始化slave
src/java/com/taobao/top/analysis/TopAnalysisNode.java:284
↓ 1 callersMethodbuildTasks
(Job job)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1020
↓ 1 callersMethodcalculator
(Object[] content)
src/java/com/taobao/top/analysis/statistics/data/ICalculator.java:7
↓ 1 callersMethodchangeMaster
运行期可以切换主master @param master
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:48
↓ 1 callersMethodcheckConfigModified
()
src/java/com/taobao/top/analysis/TopAnalysisNode.java:320
↓ 1 callersMethodcheckJobTimeOut
()
src/java/com/taobao/top/analysis/node/job/Job.java:308
↓ 1 callersMethodcheckKeyCondition
返回是否符合条件 @param operator @param conditionKey @param conditionValue @param contents @return
src/java/com/taobao/top/analysis/statistics/data/impl/SimpleCondition.java:179
↓ 1 callersMethodcheckTaskStatus
()
src/java/com/taobao/top/analysis/node/component/JobManager.java:938
↓ 1 callersMethodclean
()
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:59
↓ 1 callersMethodcleanPeriodData
(Map<String, Map<String, Object>> result, Map<String, ReportEntry> entryPool)
src/java/com/taobao/top/analysis/util/ReportUtil.java:689
↓ 1 callersMethodclearJobData
清除掉某一个job在内存的数据 @param 任务名称
src/java/com/taobao/top/analysis/node/IJobManager.java:66
↓ 1 callersMethodclone
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:213
↓ 1 callersMethodcloneResultFromTrunk
将主干上属于distinct count部分数据保留下来不输出,其他内容都输出且清空 @return
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:621
↓ 1 callersMethodcompareTo
(MemberWeight o)
src/java/com/taobao/top/analysis/util/ReportUtil.java:1513
↓ 1 callersMethodconvertStringToMap
将string转为map简单实现 @param string @param recordSplit @param mapSplit @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:322
↓ 1 callersMethodcreateDCEntryValue
(ReportEntry entry)
src/java/com/taobao/top/analysis/statistics/reduce/group/DistinctCountFunction.java:86
↓ 1 callersMethodcreateGroupNodesIfNotExist
(ZooKeeper zk,String groupId)
src/java.test/com/taobao/top/analysis/TestZookeeper.java:76
↓ 1 callersMethodcreatePath
循环创建路径中不存在的节点 @param zk @param path @throws InterruptedException @throws KeeperException
src/java/com/taobao/top/analysis/util/ZKUtil.java:150
↓ 1 callersMethodcreateReportFile
(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 callersMethodcreateTimeStampFile
(String dir)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:349
↓ 1 callersMethoddeleteData
()
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:336
↓ 1 callersMethoddoExport
(JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:37
↓ 1 callersMethoddraw
(Map<String, List<SlaveMonitorInfo>> snapshot)
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:204
↓ 1 callersMethodechoSendMonitorInfo
(String sequence, MasterMonitorInfo info, Object channel)
src/java/com/taobao/top/analysis/node/component/MasterNode.java:202
↓ 1 callersMethodechoSendMonitorInfo
响应发送监控信息请求 @param event
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:38
↓ 1 callersMethodequals
(Object obj)
src/java/com/taobao/top/analysis/config/AbstractConfig.java:255
↓ 1 callersMethodexecutedTask
任务执行统计 @param count
src/java/com/taobao/top/analysis/node/component/SlaveMonitor.java:101
↓ 1 callersMethodexportEntryData
导出分析器某一个job主干的中间分析数据 @param job
src/java/com/taobao/top/analysis/node/IJobExporter.java:43
↓ 1 callersMethodexportEntryData
(Job job)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:377
↓ 1 callersMethodexportJobData
导出内存任务数据到磁盘 @param 需要导出的任务
src/java/com/taobao/top/analysis/node/IJobManager.java:48
↓ 1 callersMethodexportJobMonitorInfo
导出Job级别的监控信息
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:546
↓ 1 callersMethodexportJobTaskMonitorInfo
()
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:613
↓ 1 callersMethodexportOrCleanTrunk
在导出数据以后,判断是否需要清空主干,是否需要导出主干 @param job
src/java/com/taobao/top/analysis/node/component/JobManager.java:864
↓ 1 callersMethodexportSystemMonitorInfo
导出系统级别的监控信息
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:495
↓ 1 callersMethodfilter
生成了value之后用来过滤生成的value的 @param value @return
src/java/com/taobao/top/analysis/statistics/data/IFilter.java:16
↓ 1 callersMethodformatValue
格式化结果,很消耗... @param formatStack @param value @return
src/java/com/taobao/top/analysis/util/ReportUtil.java:525
↓ 1 callersMethodgenerateValue
(ReportEntry entry,Object[] contents, JobTask jobtask)
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:45
↓ 1 callersMethodget
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 callersMethodgetAveragePullTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:165
↓ 1 callersMethodgetAveragePulledTaskCount
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:173
↓ 1 callersMethodgetAverageTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:181
↓ 1 callersMethodgetBloomFilter
()
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:27
↓ 1 callersMethodgetByteSize
Size of the bloom, in bytes @return
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:73
↓ 1 callersMethodgetConfigFromProps
(String jobName,JobConfig jobConfig,Properties prop)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:290
↓ 1 callersMethodgetDate
()
src/java/com/taobao/top/analysis/node/io/HubInputAdaptor.java:144
↓ 1 callersMethodgetEfficiency
()
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:94
↓ 1 callersMethodgetFile
()
src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:42
↓ 1 callersMethodgetFileBegin
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:137
↓ 1 callersMethodgetFileLen
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:645
↓ 1 callersMethodgetFileLength
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:140
↓ 1 callersMethodgetFnLen
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:651
↓ 1 callersMethodgetFormatStack
()
src/java/com/taobao/top/analysis/statistics/data/impl/SimpleFilter.java:41
↓ 1 callersMethodgetFunction
(String value)
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunctionFactory.java:21
↓ 1 callersMethodgetGroupConfigZKPath
获得某一个group的config节点 @param groupId @return
src/java/com/taobao/top/analysis/util/ZKUtil.java:92
↓ 1 callersMethodgetGroupId
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:165
↓ 1 callersMethodgetHttpContext
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:170
↓ 1 callersMethodgetHttpPort
()
src/java/com/taobao/top/analysis/config/AbstractConfig.java:163
↓ 1 callersMethodgetInputFormJob
(JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/io/IInputAdaptor.java:21
↓ 1 callersMethodgetInputFormJob
(JobTask jobtask, JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/io/HdfsInputAdaptor.java:31
↓ 1 callersMethodgetJobBuilder
()
src/java/com/taobao/top/analysis/node/IJobManager.java:81
↓ 1 callersMethodgetJobExportTime
()
src/java/com/taobao/top/analysis/node/job/Job.java:412
↓ 1 callersMethodgetJobName
@return the jobName
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:185
↓ 1 callersMethodgetJobSourceTimeStamp
@return the jobSourceTimeStamp
src/java/com/taobao/top/analysis/node/job/JobTask.java:264
↓ 1 callersMethodgetJvmFreeMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:110
↓ 1 callersMethodgetJvmMaxMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:118
↓ 1 callersMethodgetJvmPeakThreadCount
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:134
↓ 1 callersMethodgetJvmThreadCount
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:126
↓ 1 callersMethodgetJvmTotalMemory
()
src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:102
↓ 1 callersMethodgetLastExportTime
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:117
↓ 1 callersMethodgetManifestAttr
获取MANIFEST.MF文件中的属性 @param attr @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:53
↓ 1 callersMethodgetManifestBuildDate
获取MANIFEST.MF文件的创建时间作为打包时间 @return
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:71
↓ 1 callersMethodgetMasterConnector
()
src/java/com/taobao/top/analysis/node/component/MasterNode.java:73
↓ 1 callersMethodgetMasterPort
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:238
↓ 1 callersMethodgetMasters
@return the masters
src/java/com/taobao/top/analysis/statistics/data/Rule.java:167
← previousnext →401–500 of 1,163, ranked by callers