Functions — github.com/cenwenchu/beatles

hub / github.com/cenwenchu/beatles / functions

Functions1,163 in github.com/cenwenchu/beatles

⨍ Functions 1,163◇ Types & classes 171

↓ 2 callersMethodgetFileLength

@return the fileLength

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:128

↓ 2 callersMethodgetFileName

()

src/java/com/taobao/top/analysis/HttpAgentNode.java:627

↓ 2 callersMethodgetHubCursorStep

()

src/java/com/taobao/top/analysis/config/JobConfig.java:280

↓ 2 callersMethodgetInnerKeys

()

src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:114

↓ 2 callersMethodgetInputEncoding

()

src/java/com/taobao/top/analysis/node/job/JobTask.java:216

↓ 2 callersMethodgetInputStreamFromFile

(String file)

src/java/com/taobao/top/analysis/util/ReportUtil.java:82

↓ 2 callersMethodgetInstance

()

src/java/com/taobao/top/analysis/util/bloom/MurmurHash.java:16

↓ 2 callersMethodgetIp

()

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:94

↓ 2 callersMethodgetJobDataSize

()

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:49

↓ 2 callersMethodgetJobDataSize

()

src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:116

↓ 2 callersMethodgetJobInterval

()

src/java/com/taobao/top/analysis/config/SlaveConfig.java:227

↓ 2 callersMethodgetJobMergeBranchCount

()

src/java/com/taobao/top/analysis/node/job/Job.java:275

↓ 2 callersMethodgetJobMergeTime

()

src/java/com/taobao/top/analysis/node/job/Job.java:271

↓ 2 callersMethodgetKey

()

src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:36

↓ 2 callersMethodgetLastExportTime

()

src/java/com/taobao/top/analysis/node/job/Job.java:521

↓ 2 callersMethodgetMapClass

()

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:153

↓ 2 callersMethodgetMasterMonitorInfo

()

src/java/com/taobao/top/analysis/node/event/SendMonitorInfoResponseEvent.java:29

↓ 2 callersMethodgetMaxTransJobCount

()

src/java/com/taobao/top/analysis/config/SlaveConfig.java:249

↓ 2 callersMethodgetMultiSendResult

()

src/java/com/taobao/top/analysis/config/SlaveConfig.java:286

↓ 2 callersMethodgetNeedLoadResultFile

()

src/java/com/taobao/top/analysis/node/job/Job.java:402

↓ 2 callersMethodgetPipeline

()

src/java/com/taobao/top/analysis/node/connect/SocketSlaveConnector.java:85

↓ 2 callersMethodgetRebuildStatus

@return the rebuildStatus

src/java/com/taobao/top/analysis/node/job/JobTask.java:294

↓ 2 callersMethodgetReduceClass

()

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:162

↓ 2 callersMethodgetReferEntries

@return the referEntries

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:235

↓ 2 callersMethodgetResponse

()

src/java/com/taobao/top/analysis/node/event/SendResultsResponseEvent.java:25

↓ 2 callersMethodgetSlaveIpCondition

()

src/java/com/taobao/top/analysis/config/JobConfig.java:310

↓ 2 callersMethodgetSlaveReportMonitorInterval

()

src/java/com/taobao/top/analysis/config/SlaveConfig.java:260

↓ 2 callersMethodgetSourceTimeStamp

(Job job, MasterConfig config)

src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:198

↓ 2 callersMethodgetSplitRegex

()

src/java/com/taobao/top/analysis/node/job/JobTask.java:210

↓ 2 callersMethodgetStartTime

()

src/java/com/taobao/top/analysis/node/job/JobTask.java:168

↓ 2 callersMethodgetSubKeys

()

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:204

↓ 2 callersMethodgetSystemLoadAverage

()

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:158

↓ 2 callersMethodgetSystemName

()

src/java/com/taobao/top/analysis/config/AbstractConfig.java:120

↓ 2 callersMethodgetTaskRecycleTime

()

src/java/com/taobao/top/analysis/node/job/JobTask.java:223

↓ 2 callersMethodgetTimestamp

@return the timestamp

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:140

↓ 2 callersMethodgetTotalLine

()

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:55

↓ 2 callersMethodgetTotalLine

()

src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:119

↓ 2 callersMethodgetValueCount

()

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:79

↓ 2 callersMethodgetValueFilter

()

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:192

↓ 2 callersMethodgetWeight

()

src/java/com/taobao/top/analysis/util/ReportUtil.java:1498

↓ 2 callersMethodignore

(String input)

src/java/com/taobao/top/analysis/node/io/IInputAdaptor.java:23

↓ 2 callersMethodincKeyCount

(int count)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:86

↓ 2 callersMethodincValueCount

(int count)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:90

↓ 2 callersMethodinit

(Map<String, Alias> aliasPool)

src/java/com/taobao/top/analysis/statistics/data/impl/SimpleCondition.java:46

↓ 2 callersMethodisEnableAlert

()

src/java/com/taobao/top/analysis/config/AbstractConfig.java:132

↓ 2 callersMethodisModified

判断是否修改用于判断是否任务需要重新build @return

src/java/com/taobao/top/analysis/node/IJobBuilder.java:74

↓ 2 callersMethodisNeedRebuild

判断是否需要重新载入 @return

src/java/com/taobao/top/analysis/node/IJobBuilder.java:55

↓ 2 callersMethodisPeriod

@return the period

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:223

↓ 2 callersMethodisSuccess

()

src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:134

↓ 2 callersMethodisUseAsynModeToSendResponse

()

src/java/com/taobao/top/analysis/config/MasterConfig.java:216

↓ 2 callersMethodlazyMerge

(Map<String, Map<String, Object>> result, Map<String, ReportEntry> entryPool)

src/java/com/taobao/top/analysis/util/ReportUtil.java:724

↓ 2 callersMethodloadDataToTmp

(Job job, MasterConfig config)

src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:388

↓ 2 callersMethodloadJobBackupData

从某一个年代载入job的临时数据开始恢复 @param jobName @param epoch

src/java/com/taobao/top/analysis/node/IJobManager.java:73

↓ 2 callersMethodmarshal

将config中需要序列化的内容序列化成为字符串 @return

src/java/com/taobao/top/analysis/config/IConfig.java:46

↓ 2 callersMethodparseName

解析字符或者编码后的字符 @param s @param sb @return

src/java/com/taobao/top/analysis/HttpAgentNode.java:699

↓ 2 callersMethodrebuild

(Map<String,Job> jobs)

src/java/com/taobao/top/analysis/node/component/MixJobBuilder.java:116

↓ 2 callersMethodreducer

聚合 @param entry @param key @param value @param result

src/java/com/taobao/top/analysis/statistics/reduce/IReducer.java:42

↓ 2 callersMethodreport

接收Slave的监控信息, 只有一个线程会调用 @param info

src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:98

↓ 2 callersMethodrun

()

src/java/com/taobao/top/analysis/node/component/JobManager.java:351

↓ 2 callersMethodsanityCheck

()

src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:123

↓ 2 callersMethodsetAnalysisConsume

(long analysisConsume)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:46

↓ 2 callersMethodsetCondition

(String condition)

src/java/com/taobao/top/analysis/statistics/data/Report.java:49

↓ 2 callersMethodsetDiskResult

(Map<String, Map<String, Object>> diskResult)

src/java/com/taobao/top/analysis/node/job/Job.java:516

↓ 2 callersMethodsetEmptyLine

(long emptyLine)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:70

↓ 2 callersMethodsetEndTime

(long endTime)

src/java/com/taobao/top/analysis/node/job/JobTask.java:177

↓ 2 callersMethodsetErrorLine

(long errorLine)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:64

↓ 2 callersMethodsetEventCode

(SlaveEventCode eventCode)

src/java/com/taobao/top/analysis/node/event/SlaveNodeEvent.java:51

↓ 2 callersMethodsetIp

(String ip)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:98

↓ 2 callersMethodsetJobBuilder

(IJobBuilder jobBuilder)

src/java/com/taobao/top/analysis/node/IJobManager.java:83

↓ 2 callersMethodsetJobBuilder

(IJobBuilder jobBuilder)

src/java/com/taobao/top/analysis/node/component/JobManager.java:992

↓ 2 callersMethodsetJobDataSize

(long jobDataSize)

src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:52

↓ 2 callersMethodsetJobEpoch

(int jobEpoch)

src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:107

↓ 2 callersMethodsetJobExporter

(IJobExporter jobExporter)

src/java/com/taobao/top/analysis/node/component/JobManager.java:1004

↓ 2 callersMethodsetJobExporter

(IJobExporter jobExporter)

src/java/com/taobao/top/analysis/node/io/FileOutputAdaptor.java:34

↓ 2 callersMethodsetJobManager

(IJobManager jobManager)

src/java/com/taobao/top/analysis/node/component/MasterNode.java:69

↓ 2 callersMethodsetJobName

(String jobName)

src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:43

↓ 2 callersMethodsetJobResultMerger

(IJobResultMerger jobResultMerger)

src/java/com/taobao/top/analysis/node/component/JobManager.java:1016

↓ 2 callersMethodsetJobResultMerger

(IJobResultMerger jobResultMerger)

src/java/com/taobao/top/analysis/node/component/SlaveNode.java:133

↓ 2 callersMethodsetJobSourceTimeStamp

(long jobSourceTimeStamp)

src/java/com/taobao/top/analysis/node/job/Job.java:246

↓ 2 callersMethodsetJobTaskResult

(JobTaskResult jobTaskResult)

src/java/com/taobao/top/analysis/node/event/SendResultsRequestEvent.java:35

↓ 2 callersMethodsetJvmFreeMemory

(Long jvmFreeMemory)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:114

↓ 2 callersMethodsetJvmMaxMemory

(Long jvmMaxMemory)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:122

↓ 2 callersMethodsetJvmPeakThreadCount

(Integer jvmPeakThreadCount)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:138

↓ 2 callersMethodsetJvmThreadCount

(Integer jvmThreadCount)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:130

↓ 2 callersMethodsetJvmTotalMemory

(Long jvmTotalMemory)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:106

↓ 2 callersMethodsetKey

(int key)

src/java/com/taobao/top/analysis/statistics/data/Alias.java:32

↓ 2 callersMethodsetKeys

(int[] keys)

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:201

↓ 2 callersMethodsetLastMergedEpoch

(int lastMergedEpoch)

src/java/com/taobao/top/analysis/node/job/JobTask.java:122

↓ 2 callersMethodsetLazy

(boolean lazy)

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:137

↓ 2 callersMethodsetMasterNode

(MasterNode masterNode)

src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:20

↓ 2 callersMethodsetMaxEventHoldTime

(long maxEventHoldTime)

src/java/com/taobao/top/analysis/util/TimeOutEvent.java:29

↓ 2 callersMethodsetMonitor

(MasterMonitor monitor)

src/java/com/taobao/top/analysis/node/component/MasterNode.java:85

↓ 2 callersMethodsetName

(String name)

src/java/com/taobao/top/analysis/statistics/data/Alias.java:24

↓ 2 callersMethodsetNeedRebuild

设置重新载入 @param needRebuild

src/java/com/taobao/top/analysis/node/IJobBuilder.java:61

↓ 2 callersMethodsetOsName

(String osName)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:146

↓ 2 callersMethodsetOsVersion

(String osVersion)

src/java/com/taobao/top/analysis/node/monitor/MonitorInfo.java:154

↓ 2 callersMethodsetPeriod

(boolean period)

src/java/com/taobao/top/analysis/statistics/data/Report.java:65

↓ 2 callersMethodsetReduceClass

(IReducer reduceClass)

src/java/com/taobao/top/analysis/statistics/data/ReportEntry.java:165

↓ 2 callersMethodsetReport

采用递归来设置每一个entry的报表

src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:357

↓ 2 callersMethodsetReportEntry

构建报表entry对象 @param 是否是公用的entry ，非公用的定义在report对象中 @param 数据节点 @param 当前处理的entry @param 当前隶属的report ，这个值只有在非公用的entry解析的时候用到 @para

src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:774

← previous next →301–400 of 1,163, ranked by callers