Functions — github.com/cenwenchu/beatles

hub / github.com/cenwenchu/beatles / functions

Functions1,163 in github.com/cenwenchu/beatles

⨍ Functions 1,163◇ Types & classes 171

↓ 6 callersMethodgetMapInstance

()

src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:156

↓ 6 callersMethodgetReferEntrys

()

src/java/com/taobao/top/analysis/statistics/data/Rule.java:112

↓ 6 callersMethodgetReportPeriodFlag

()

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

↓ 6 callersMethodgetSequence

()

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:49

↓ 6 callersMethodgetStatus

()

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

↓ 6 callersMethodgetTailCursor

@return the tailCursor

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

↓ 6 callersMethodgetTimestampMap

@return the timestampMap

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

↓ 6 callersMethodinit

()

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

↓ 6 callersMethodload

私有扁平化载入 @param totalFiles @return @throws AnalysisException

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

↓ 6 callersMethodrelease

()

src/java/com/taobao/top/analysis/util/TimeOutQueue.java:51

↓ 6 callersMethodreleaseResource

()

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

↓ 6 callersMethodsetChannel

(Object channel)

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

↓ 6 callersMethodsetConfig

(MasterConfig config)

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

↓ 6 callersMethodsetFileBegin

@param fileBegin the fileBegin to set

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

↓ 6 callersMethodsetJobSourceTimeStamp

@param jobSourceTimeStamp the jobSourceTimeStamp to set

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

↓ 6 callersMethodsetStatus

(JobTaskStatus status)

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

↓ 6 callersMethodstartNode

启动节点

src/java/com/taobao/top/analysis/node/INode.java:41

↓ 6 callersMethodupdateOrCreateNode

(ZooKeeper zk,String path,byte[] data)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:120

↓ 5 callersMethodcreateNodeIfNotExist

(ZooKeeper zk,String path,byte[] data)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:110

↓ 5 callersMethodcreateNodeIfNotExist

节点基础操作，根据路径判断是否存在该节点，不存在就创建，存在则不处理 @param zk @param path @param data @throws KeeperException @throws InterruptedException

src/java/com/taobao/top/analysis/util/ZKUtil.java:106

↓ 5 callersMethodgenerateOperationFlag

(String operation)

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

↓ 5 callersMethodgetAnalysisConsume

()

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

↓ 5 callersMethodgetBranchResultQueuePool

()

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

↓ 5 callersMethodgetCondition

()

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

↓ 5 callersMethodgetConfigFile

@return the configFile

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

↓ 5 callersMethodgetGroupMasterZKPath

获得某一个group的master节点 @param groupId @return

src/java/com/taobao/top/analysis/util/ZKUtil.java:72

↓ 5 callersMethodgetGroupSlaveZKPath

(String groupId)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:99

↓ 5 callersMethodgetGroupZKPath

(String groupId)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:88

↓ 5 callersMethodgetGroupZKPath

获得某一个group的zk节点 @param groupId @return

src/java/com/taobao/top/analysis/util/ZKUtil.java:61

↓ 5 callersMethodgetInput

()

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

↓ 5 callersMethodgetJobEpoch

()

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

↓ 5 callersMethodgetJobSourceTimeStamp

()

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

↓ 5 callersMethodgetJobTasks

()

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

↓ 5 callersMethodgetJobTimeOut

()

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

↓ 5 callersMethodgetMasterAddress

()

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

↓ 5 callersMethodgetMaxClientEventWaitTime

()

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

↓ 5 callersMethodgetResponse

()

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:41

↓ 5 callersMethodgetTaskExecuteInfos

()

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

↓ 5 callersMethodmergeEntryResult

合并结果集 @param resultPools @param entryPool @return

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

↓ 5 callersMethodrebuild

重新载入 @return @throws AnalysisException

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

↓ 5 callersMethodreleaseResource

()

src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:97

↓ 5 callersMethodsetJobExporter

(IJobExporter jobExporter)

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

↓ 5 callersMethodsetMapClass

(IMapper mapClass)

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

↓ 4 callersMethodadd

(String key)

src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:34

↓ 4 callersMethodaddInputAdaptor

(IInputAdaptor inputAdaptor)

src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:29

↓ 4 callersMethodaddOutputAdaptor

(IOutputAdaptor outputAdaptor)

src/java/com/taobao/top/analysis/statistics/StatisticsEngine.java:94

↓ 4 callersMethodbuild

()

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

↓ 4 callersMethodbuildSlave

(String configfile,boolean needStart)

src/java.test/com/taobao/top/analysis/node/component/MasterSlaveIntegrationTest_SocketVersion.java:67

↓ 4 callersMethodcovertNullToEmpty

将NULL转为空字符串 @param str @return

src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:148

↓ 4 callersMethodechoGetJobTasks

响应获取任务数据的请求 @param 请求事件

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

↓ 4 callersMethodgenerateSendResultsRequestEvent

(JobTaskResult jobTaskResult)

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

↓ 4 callersMethodgetAdditions

()

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

↓ 4 callersMethodgetAlertFrom

()

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

↓ 4 callersMethodgetAlertModel

()

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

↓ 4 callersMethodgetAlertUrl

()

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

↓ 4 callersMethodgetAlertWangWang

()

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

↓ 4 callersMethodgetBindingStack

()

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

↓ 4 callersMethodgetDestDir

(Job job, MasterConfig config)

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

↓ 4 callersMethodgetGroupConfigZKPath

(String groupId)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:104

↓ 4 callersMethodgetGroupFunction

()

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

↓ 4 callersMethodgetGroupMasterZKPath

(String groupId)

src/java.test/com/taobao/top/analysis/TestZookeeper.java:94

↓ 4 callersMethodgetInputParams

()

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

↓ 4 callersMethodgetJobResetTime

()

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

↓ 4 callersMethodgetJobTaskPool

@return the jobTaskPool

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

↓ 4 callersMethodgetJobsSource

()

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

↓ 4 callersMethodgetKeyCount

The number of keys added to the bloom @return

src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:61

↓ 4 callersMethodgetLoadLock

()

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

↓ 4 callersMethodgetMasterSide

()

src/java/com/taobao/top/analysis/node/connect/MemTunnel.java:45

↓ 4 callersMethodgetName

()

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

↓ 4 callersMethodgetOperatorStack

()

src/java/com/taobao/top/analysis/statistics/data/impl/SimpleCalculator.java:53

↓ 4 callersMethodgetRebuildTag

@return the rebuildTag

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

↓ 4 callersMethodgetRecycleCounter

()

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

↓ 4 callersMethodgetResource

()

src/java/com/taobao/top/analysis/node/job/JobResource.java:76

↓ 4 callersMethodgetResultReadyFlag

()

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:65

↓ 4 callersMethodgetSeparator

()

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

↓ 4 callersMethodgetSlavePulledTaskCount

()

src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:197

↓ 4 callersMethodgetSlaveTryPullTaskCount

()

src/java/com/taobao/top/analysis/node/monitor/SlaveMonitorInfo.java:149

↓ 4 callersMethodgetStatusPool

@return the statusPool

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

↓ 4 callersMethodgetSubKeyName

()

src/java/com/taobao/top/analysis/statistics/data/ObjectColumn.java:34

↓ 4 callersMethodgetValueFromJosnObj

简单的从column 的json对象中获得对应属性的结果 @param column @param subKeyName

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

↓ 4 callersMethodhash

(byte[] data, int offset, int length, int seed)

src/java/com/taobao/top/analysis/util/bloom/Hash.java:14

↓ 4 callersMethodisLazy

()

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

↓ 4 callersMethodmerge

(Job job,BlockingQueue<JobMergedResult> branchResultQueue ,BlockingQueue<JobTaskResult> jobTaskResultsQueu

src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:99

↓ 4 callersMethodnewInstance

创建实例 @param <I> @param interfaceDefinition @param className @param classLoader @return

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

↓ 4 callersMethodreset

(JobManager jobManager)

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

↓ 4 callersMethodrun

()

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

↓ 4 callersMethodsendOutAlert

(final Calendar calendar, final String alertURL, final String alertFrom, final Strin

src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:81

↓ 4 callersMethodsetEventCreateTime

(long eventCreateTime)

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:78

↓ 4 callersMethodsetFileLength

@param fileLength the fileLength to set

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

↓ 4 callersMethodsetInput

(String input)

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

↓ 4 callersMethodsetJobName

@param jobName the jobName to set

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

↓ 4 callersMethodsetMapParams

(String mapParams)

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

↓ 4 callersMethodsetMasterConnector

(IMasterConnector masterConnector)

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

↓ 4 callersMethodsetMaxCreateReportWorker

(int maxCreateReportWorker)

src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:64

↓ 4 callersMethodsetMaxEventHoldTime

(long maxEventHoldTime)

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:87

↓ 4 callersMethodsetSequence

(String sequence)

src/java/com/taobao/top/analysis/node/event/MasterNodeEvent.java:53

↓ 4 callersMethodsetSlaveConnector

(ISlaveConnector slaveConnector)

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

↓ 4 callersMethodsetTaskId

(String taskId)

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

↓ 4 callersMethodsetTimestamp

@param timestamp the timestamp to set

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

↓ 4 callersMethodupdateOrCreateNode

节点基础操作，根据路径判断节点是否存在，如果存在则更新数据，如果不存在则创建节点 @param zk @param path @param data @throws KeeperException @throws InterruptedException

src/java/com/taobao/top/analysis/util/ZKUtil.java:124

← previous next →101–200 of 1,163, ranked by callers