MCPcopy Create free account

hub / github.com/cenwenchu/beatles / functions

Functions1,163 in github.com/cenwenchu/beatles

↓ 3 callersMethodSimpleAllocationAlgorithm
简单的支持双向权重的分配算法 @param 资源要分配的对象,支持member split weight的表示方法 @param 对象要获得的资源,支持resource split weight的表示方法 @return resource:member
src/java/com/taobao/top/analysis/util/ReportUtil.java:1196
↓ 3 callersMethodaddReport
(Report report)
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:127
↓ 3 callersMethodaddTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:476
↓ 3 callersMethodclone
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:216
↓ 3 callersMethodcompareTo
(TimeOutEvent event)
src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:91
↓ 3 callersMethodcreateGroupNodesIfNotExist
创建某一个Group的配直节点 @param zk @param groupId @throws KeeperException @throws InterruptedException
src/java/com/taobao/top/analysis/util/ZKUtil.java:44
↓ 3 callersMethoddoAnalysis
(JobTask jobTask)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:35
↓ 3 callersMethodgenerateJobInputAddition
(String input,Job job)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1008
↓ 3 callersMethodgenerateValue
@param 报表entry定义 @param 日志切割后的字符串数组 @param 别名定义 @return
src/java/com/taobao/top/analysis/node/reduce/IReportReduce.java:23
↓ 3 callersMethodgenerteOutputDirectoryName
@return
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:457
↓ 3 callersMethodgetAsynLoadDiskFilePrecent
()
src/java/com/taobao/top/analysis/config/JobConfig.java:265
↓ 3 callersMethodgetAttachment
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:31
↓ 3 callersMethodgetBegin
()
src/java/com/taobao/top/analysis/config/JobConfig.java:292
↓ 3 callersMethodgetCompletedTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:489
↓ 3 callersMethodgetCount
()
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:21
↓ 3 callersMethodgetDiskResult
()
src/java/com/taobao/top/analysis/node/job/Job.java:511
↓ 3 callersMethodgetFisList
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:634
↓ 3 callersMethodgetGroupSlaveZKPath
获得某一个group的slave节点 @param groupId @return
src/java/com/taobao/top/analysis/util/ZKUtil.java:82
↓ 3 callersMethodgetInit
()
src/java/com/taobao/top/analysis/config/JobConfig.java:303
↓ 3 callersMethodgetInnerKeyPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:100
↓ 3 callersMethodgetMapParam
()
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:161
↓ 3 callersMethodgetMasterGroup
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:204
↓ 3 callersMethodgetMaxEventHoldTime
当前事件最大有效期,单位秒 @return
src/java/com/taobao/top/analysis/util/TimeOutEvent.java:27
↓ 3 callersMethodgetMaxJobEventWorker
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:262
↓ 3 callersMethodgetOutputEncoding
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:147
↓ 3 callersMethodgetReduceParams
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:174
↓ 3 callersMethodgetReportPeriodDefine
()
src/java/com/taobao/top/analysis/config/JobConfig.java:149
↓ 3 callersMethodgetReportToMaster
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:357
↓ 3 callersMethodgetReports
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:121
↓ 3 callersMethodgetRequestJobCount
()
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:47
↓ 3 callersMethodgetSlaveMonitorInfo
()
src/java/com/taobao/top/analysis/node/event/SendMonitorInfoEvent.java:29
↓ 3 callersMethodgetSlaveName
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:135
↓ 3 callersMethodgetSlavePullTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:157
↓ 3 callersMethodgetTaskIdFromUrl
(final String jobName, final String url, final int taskCount)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1156
↓ 3 callersMethodgetTempStoreDataDir
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:148
↓ 3 callersMethodgetTempStoreDataFile
(String master,String jobName)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:655
↓ 3 callersMethodhandleTaskResult
(final JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:401
↓ 3 callersMethodinit
(String key,int weight)
src/java/com/taobao/top/analysis/util/ReportUtil.java:1478
↓ 3 callersMethodinit
()
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:63
↓ 3 callersMethodinit
()
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:967
↓ 3 callersMethodinnerLoad
(boolean onlyLoadSourceTimestamp, Job job, MasterConfig config)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:283
↓ 3 callersMethodisAppend
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:125
↓ 3 callersMethodisExported
()
src/java/com/taobao/top/analysis/node/job/Job.java:506
↓ 3 callersMethodisExporting
()
src/java/com/taobao/top/analysis/node/job/Job.java:438
↓ 3 callersMethodisMerging
()
src/java/com/taobao/top/analysis/node/job/Job.java:433
↓ 3 callersMethodisPeriod
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:61
↓ 3 callersMethodloadData
(Job job, MasterConfig config)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:407
↓ 3 callersMethodmerge
用于Master的合并 合并某一个job的所有可以合并的结果,当前默认实现是多线程合并(主干只是单线程竞争合并) @param job @param 分支队列,支持多个线程同时合并,不需要等待主干合并结束顺序化合并 @param 需要合并的结果集合 @param 是否需要合并的时候处理一些lazy的
src/java/com/taobao/top/analysis/node/IJobResultMerger.java:32
↓ 3 callersMethodrebuild
这里的逻辑是第一次调用该方法,置标记位 第二次调用,真正rebuild 标记重构,保证在任务执行结束后再重构,无缝重载 采用这种逻辑的目的是入口统一 此处代码可用其他结构实现,可以从设计模式及性能上面考虑 @param job
src/java/com/taobao/top/analysis/node/job/Job.java:549
↓ 3 callersMethodreleaseResource
()
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:80
↓ 3 callersMethodsetBloomFilter
(ByteBloomFilter bloomFilter)
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:30
↓ 3 callersMethodsetConfig
(MasterConfig config)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:74
↓ 3 callersMethodsetDownstreamHandler
(ChannelDownstreamHandler downstreamHandler)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:363
↓ 3 callersMethodsetEfficiency
(float efficiency)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:98
↓ 3 callersMethodsetId
(String id)
src/java/com/taobao/top/analysis/statistics/data/Report.java:89
↓ 3 callersMethodsetJobManager
@param jobManager the jobManager to set
src/java/com/taobao/top/analysis/HttpAgentNode.java:93
↓ 3 callersMethodsetJobName
(String jobName)
src/java/com/taobao/top/analysis/node/job/JobTask.java:141
↓ 3 callersMethodsetJobResultMerger
(IJobResultMerger jobResultMerger)
src/java/com/taobao/top/analysis/node/IJobManager.java:91
↓ 3 callersMethodsetMonitor
(SlaveMonitor monitor)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:137
↓ 3 callersMethodsetReportPeriodFlag
(int reportPeriodFlag)
src/java/com/taobao/top/analysis/node/job/Job.java:536
↓ 3 callersMethodsetResults
(Map<String, Map<String, Object>> results)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:153
↓ 3 callersMethodsetStatisticsEngine
(IStatisticsEngine statisticsEngine)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:117
↓ 3 callersMethodsetStatisticsRule
(Rule statisticsRule)
src/java/com/taobao/top/analysis/node/job/JobTask.java:195
↓ 3 callersMethodsetSuccess
(boolean success)
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:39
↓ 3 callersMethodsetUpstreamHandler
(ChannelUpstreamHandler upstreamHandler)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:371
↓ 3 callersMethodsetUrl
@param url the url to set
src/java/com/taobao/top/analysis/node/job/JobTask.java:243
↓ 3 callersMethodsetZk
(ZooKeeper zk)
src/java/com/taobao/top/analysis/util/AnalyzerZKWatcher.java:40
↓ 3 callersMethodsize
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:622
↓ 2 callersMethodaddTaskExecuteInfo
(JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:117
↓ 2 callersMethodaddTaskId
(String taskId)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:112
↓ 2 callersMethodaddTaskResultToQueue
增加Slave计算后的返回结果 @param 分析后结果
src/java/com/taobao/top/analysis/node/IJobManager.java:42
↓ 2 callersMethodallocBloom
()
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:149
↓ 2 callersMethodallocateTask
(JobTask jobTask)
src/java/com/taobao/top/analysis/node/component/JobManager.java:367
↓ 2 callersMethodanalysisMapParams
(String mapParams)
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:109
↓ 2 callersMethodawaitNode
()
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:83
↓ 2 callersMethodbuild
默认从config获得job编译路径 @return @throws AnalysisException
src/java/com/taobao/top/analysis/node/IJobBuilder.java:27
↓ 2 callersMethodbuildReportModule
编译分析规则模型 @param 配置文件 @param entry定义池 @param 父级entry定义池 @param 报表定义池 @param 别名定义池 @param 告警定义池 @throws IOException @throws XMLStreamException
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:385
↓ 2 callersMethodcheckJobStatus
包括重新载入任务列表,检查Task执行状况判断是否需要重置,检查Job状态判断是否需要导出,重置,合并结果 @throws AnalysisException
src/java/com/taobao/top/analysis/node/IJobManager.java:30
↓ 2 callersMethodcleanLazyData
(Map<String, Map<String, Object>> result, Map<String, ReportEntry> entryPool)
src/java/com/taobao/top/analysis/util/ReportUtil.java:668
↓ 2 callersMethodcloneWithOutResults
克隆一个对象,但不包含里面的结果集 @return @throws CloneNotSupportedException
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:76
↓ 2 callersMethodclusterLog
(String log)
src/java/com/taobao/top/analysis/util/ReportUtil.java:77
↓ 2 callersMethoddeleteNode
删除zk节点 @param zk @param path @throws KeeperException @throws InterruptedException
src/java/com/taobao/top/analysis/util/ZKUtil.java:176
↓ 2 callersMethoddoDistinct
(File f,int maxKeys,float errorRate,int distinctColumn,Integer[] groupby,Map<String,DistinctCountEntryValue>re
src/java.test/com/taobao/top/analysis/util/bloom/DistinctCountTool.java:92
↓ 2 callersMethoddoExport
(JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:104
↓ 2 callersMethodeventChainChange
当有新的事件加入状态变更等待队列, 判断最小的timeout是否发生改变,选择性唤醒checker @param node
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:176
↓ 2 callersMethodexportData
(boolean setTrunkNull)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:491
↓ 2 callersMethodexportReport
导出报表,可以实现多线程,但必须是阻塞模式 @param 需要导出的Job @param 是否需要时间后缀 @return
src/java/com/taobao/top/analysis/node/IJobExporter.java:28
↓ 2 callersMethodexportReport
(Job job, boolean needTimeSuffix)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:104
↓ 2 callersMethodgenerateKey
(ReportEntry entry,String[] contents, JobTask jobtask)
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:43
↓ 2 callersMethodgetAnalysisConsume
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:113
↓ 2 callersMethodgetAnalysisWorkerNum
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:238
↓ 2 callersMethodgetDateFormat
()
src/java/com/taobao/top/analysis/util/ThreadLocalVar.java:22
↓ 2 callersMethodgetDir
(String dir)
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:338
↓ 2 callersMethodgetEmptyLine
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:67
↓ 2 callersMethodgetEmptyLine
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:125
↓ 2 callersMethodgetErrorLine
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:61
↓ 2 callersMethodgetErrorLine
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:122
↓ 2 callersMethodgetExportInterval
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:109
↓ 2 callersMethodgetExportMonitorInterval
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:382
↓ 2 callersMethodgetFileBegin
@return the fileBegin
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:116
← previousnext →201–300 of 1,163, ranked by callers