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
↓ 3 callers
Method
SimpleAllocationAlgorithm
简单的支持双向权重的分配算法 @param 资源要分配的对象,支持member split weight的表示方法 @param 对象要获得的资源,支持resource split weight的表示方法 @return resource:member
src/java/com/taobao/top/analysis/util/ReportUtil.java:1196
↓ 3 callers
Method
addReport
(Report report)
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:127
↓ 3 callers
Method
addTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:476
↓ 3 callers
Method
clone
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:216
↓ 3 callers
Method
compareTo
(TimeOutEvent event)
src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:91
↓ 3 callers
Method
createGroupNodesIfNotExist
创建某一个Group的配直节点 @param zk @param groupId @throws KeeperException @throws InterruptedException
src/java/com/taobao/top/analysis/util/ZKUtil.java:44
↓ 3 callers
Method
doAnalysis
(JobTask jobTask)
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:35
↓ 3 callers
Method
generateJobInputAddition
(String input,Job job)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1008
↓ 3 callers
Method
generateValue
@param 报表entry定义 @param 日志切割后的字符串数组 @param 别名定义 @return
src/java/com/taobao/top/analysis/node/reduce/IReportReduce.java:23
↓ 3 callers
Method
generteOutputDirectoryName
@return
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:457
↓ 3 callers
Method
getAsynLoadDiskFilePrecent
()
src/java/com/taobao/top/analysis/config/JobConfig.java:265
↓ 3 callers
Method
getAttachment
()
src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:31
↓ 3 callers
Method
getBegin
()
src/java/com/taobao/top/analysis/config/JobConfig.java:292
↓ 3 callers
Method
getCompletedTaskCount
()
src/java/com/taobao/top/analysis/node/job/Job.java:489
↓ 3 callers
Method
getCount
()
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:21
↓ 3 callers
Method
getDiskResult
()
src/java/com/taobao/top/analysis/node/job/Job.java:511
↓ 3 callers
Method
getFisList
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:634
↓ 3 callers
Method
getGroupSlaveZKPath
获得某一个group的slave节点 @param groupId @return
src/java/com/taobao/top/analysis/util/ZKUtil.java:82
↓ 3 callers
Method
getInit
()
src/java/com/taobao/top/analysis/config/JobConfig.java:303
↓ 3 callers
Method
getInnerKeyPool
()
src/java/com/taobao/top/analysis/statistics/data/Rule.java:100
↓ 3 callers
Method
getMapParam
()
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:161
↓ 3 callers
Method
getMasterGroup
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:204
↓ 3 callers
Method
getMaxEventHoldTime
当前事件最大有效期,单位秒 @return
src/java/com/taobao/top/analysis/util/TimeOutEvent.java:27
↓ 3 callers
Method
getMaxJobEventWorker
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:262
↓ 3 callers
Method
getOutputEncoding
()
src/java/com/taobao/top/analysis/node/job/JobTask.java:147
↓ 3 callers
Method
getReduceParams
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:174
↓ 3 callers
Method
getReportPeriodDefine
()
src/java/com/taobao/top/analysis/config/JobConfig.java:149
↓ 3 callers
Method
getReportToMaster
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:357
↓ 3 callers
Method
getReports
()
src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:121
↓ 3 callers
Method
getRequestJobCount
()
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:47
↓ 3 callers
Method
getSlaveMonitorInfo
()
src/java/com/taobao/top/analysis/node/event/SendMonitorInfoEvent.java:29
↓ 3 callers
Method
getSlaveName
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:135
↓ 3 callers
Method
getSlavePullTaskConsumeTime
()
src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:157
↓ 3 callers
Method
getTaskIdFromUrl
(final String jobName, final String url, final int taskCount)
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:1156
↓ 3 callers
Method
getTempStoreDataDir
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:148
↓ 3 callers
Method
getTempStoreDataFile
(String master,String jobName)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:655
↓ 3 callers
Method
handleTaskResult
(final JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:401
↓ 3 callers
Method
init
(String key,int weight)
src/java/com/taobao/top/analysis/util/ReportUtil.java:1478
↓ 3 callers
Method
init
()
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:63
↓ 3 callers
Method
init
()
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:967
↓ 3 callers
Method
innerLoad
(boolean onlyLoadSourceTimestamp, Job job, MasterConfig config)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:283
↓ 3 callers
Method
isAppend
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:125
↓ 3 callers
Method
isExported
()
src/java/com/taobao/top/analysis/node/job/Job.java:506
↓ 3 callers
Method
isExporting
()
src/java/com/taobao/top/analysis/node/job/Job.java:438
↓ 3 callers
Method
isMerging
()
src/java/com/taobao/top/analysis/node/job/Job.java:433
↓ 3 callers
Method
isPeriod
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:61
↓ 3 callers
Method
loadData
(Job job, MasterConfig config)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:407
↓ 3 callers
Method
merge
用于Master的合并 合并某一个job的所有可以合并的结果,当前默认实现是多线程合并(主干只是单线程竞争合并) @param job @param 分支队列,支持多个线程同时合并,不需要等待主干合并结束顺序化合并 @param 需要合并的结果集合 @param 是否需要合并的时候处理一些lazy的
src/java/com/taobao/top/analysis/node/IJobResultMerger.java:32
↓ 3 callers
Method
rebuild
这里的逻辑是第一次调用该方法,置标记位 第二次调用,真正rebuild 标记重构,保证在任务执行结束后再重构,无缝重载 采用这种逻辑的目的是入口统一 此处代码可用其他结构实现,可以从设计模式及性能上面考虑 @param job
src/java/com/taobao/top/analysis/node/job/Job.java:549
↓ 3 callers
Method
releaseResource
()
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:80
↓ 3 callers
Method
setBloomFilter
(ByteBloomFilter bloomFilter)
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:30
↓ 3 callers
Method
setConfig
(MasterConfig config)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:74
↓ 3 callers
Method
setDownstreamHandler
(ChannelDownstreamHandler downstreamHandler)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:363
↓ 3 callers
Method
setEfficiency
(float efficiency)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:98
↓ 3 callers
Method
setId
(String id)
src/java/com/taobao/top/analysis/statistics/data/Report.java:89
↓ 3 callers
Method
setJobManager
@param jobManager the jobManager to set
src/java/com/taobao/top/analysis/HttpAgentNode.java:93
↓ 3 callers
Method
setJobName
(String jobName)
src/java/com/taobao/top/analysis/node/job/JobTask.java:141
↓ 3 callers
Method
setJobResultMerger
(IJobResultMerger jobResultMerger)
src/java/com/taobao/top/analysis/node/IJobManager.java:91
↓ 3 callers
Method
setMonitor
(SlaveMonitor monitor)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:137
↓ 3 callers
Method
setReportPeriodFlag
(int reportPeriodFlag)
src/java/com/taobao/top/analysis/node/job/Job.java:536
↓ 3 callers
Method
setResults
(Map<String, Map<String, Object>> results)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:153
↓ 3 callers
Method
setStatisticsEngine
(IStatisticsEngine statisticsEngine)
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:117
↓ 3 callers
Method
setStatisticsRule
(Rule statisticsRule)
src/java/com/taobao/top/analysis/node/job/JobTask.java:195
↓ 3 callers
Method
setSuccess
(boolean success)
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:39
↓ 3 callers
Method
setUpstreamHandler
(ChannelUpstreamHandler upstreamHandler)
src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:371
↓ 3 callers
Method
setUrl
@param url the url to set
src/java/com/taobao/top/analysis/node/job/JobTask.java:243
↓ 3 callers
Method
setZk
(ZooKeeper zk)
src/java/com/taobao/top/analysis/util/AnalyzerZKWatcher.java:40
↓ 3 callers
Method
size
()
src/java/com/taobao/top/analysis/HttpAgentNode.java:622
↓ 2 callers
Method
addTaskExecuteInfo
(JobTaskExecuteInfo taskExecuteInfo)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:117
↓ 2 callers
Method
addTaskId
(String taskId)
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:112
↓ 2 callers
Method
addTaskResultToQueue
增加Slave计算后的返回结果 @param 分析后结果
src/java/com/taobao/top/analysis/node/IJobManager.java:42
↓ 2 callers
Method
allocBloom
()
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:149
↓ 2 callers
Method
allocateTask
(JobTask jobTask)
src/java/com/taobao/top/analysis/node/component/JobManager.java:367
↓ 2 callers
Method
analysisMapParams
(String mapParams)
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:109
↓ 2 callers
Method
awaitNode
()
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:83
↓ 2 callers
Method
build
默认从config获得job编译路径 @return @throws AnalysisException
src/java/com/taobao/top/analysis/node/IJobBuilder.java:27
↓ 2 callers
Method
buildReportModule
编译分析规则模型 @param 配置文件 @param entry定义池 @param 父级entry定义池 @param 报表定义池 @param 别名定义池 @param 告警定义池 @throws IOException @throws XMLStreamException
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:385
↓ 2 callers
Method
checkJobStatus
包括重新载入任务列表,检查Task执行状况判断是否需要重置,检查Job状态判断是否需要导出,重置,合并结果 @throws AnalysisException
src/java/com/taobao/top/analysis/node/IJobManager.java:30
↓ 2 callers
Method
cleanLazyData
(Map<String, Map<String, Object>> result, Map<String, ReportEntry> entryPool)
src/java/com/taobao/top/analysis/util/ReportUtil.java:668
↓ 2 callers
Method
cloneWithOutResults
克隆一个对象,但不包含里面的结果集 @return @throws CloneNotSupportedException
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:76
↓ 2 callers
Method
clusterLog
(String log)
src/java/com/taobao/top/analysis/util/ReportUtil.java:77
↓ 2 callers
Method
deleteNode
删除zk节点 @param zk @param path @throws KeeperException @throws InterruptedException
src/java/com/taobao/top/analysis/util/ZKUtil.java:176
↓ 2 callers
Method
doDistinct
(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 callers
Method
doExport
(JobTask jobTask,JobTaskResult jobTaskResult)
src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:104
↓ 2 callers
Method
eventChainChange
当有新的事件加入状态变更等待队列, 判断最小的timeout是否发生改变,选择性唤醒checker @param node
src/java/com/taobao/top/analysis/util/TimeOutQueue.java:176
↓ 2 callers
Method
exportData
(boolean setTrunkNull)
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:491
↓ 2 callers
Method
exportReport
导出报表,可以实现多线程,但必须是阻塞模式 @param 需要导出的Job @param 是否需要时间后缀 @return
src/java/com/taobao/top/analysis/node/IJobExporter.java:28
↓ 2 callers
Method
exportReport
(Job job, boolean needTimeSuffix)
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:104
↓ 2 callers
Method
generateKey
(ReportEntry entry,String[] contents, JobTask jobtask)
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:43
↓ 2 callers
Method
getAnalysisConsume
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:113
↓ 2 callers
Method
getAnalysisWorkerNum
()
src/java/com/taobao/top/analysis/config/SlaveConfig.java:238
↓ 2 callers
Method
getDateFormat
()
src/java/com/taobao/top/analysis/util/ThreadLocalVar.java:22
↓ 2 callers
Method
getDir
(String dir)
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:338
↓ 2 callers
Method
getEmptyLine
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:67
↓ 2 callers
Method
getEmptyLine
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:125
↓ 2 callers
Method
getErrorLine
()
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:61
↓ 2 callers
Method
getErrorLine
()
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:122
↓ 2 callers
Method
getExportInterval
()
src/java/com/taobao/top/analysis/statistics/data/Report.java:109
↓ 2 callers
Method
getExportMonitorInterval
()
src/java/com/taobao/top/analysis/config/MasterConfig.java:382
↓ 2 callers
Method
getFileBegin
@return the fileBegin
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:116
← previous
next →
201–300 of 1,163, ranked by callers