Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cenwenchu/beatles
/ types & classes
Types & classes
171 in github.com/cenwenchu/beatles
⨍
Functions
1,163
◇
Types & classes
171
Class
AbstractConfig
配置抽象类 参数采取动态获取,每次获取都会可能产生消耗,注意使用场景 @author fangweng
src/java/com/taobao/top/analysis/config/AbstractConfig.java:27
Class
AbstractMapper
通过final限制mapper的流程 @author zhudi
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:16
Class
AbstractMasterConnector
@author fangweng @email: fangweng@taobao.com 2011-12-2 下午5:17:39
src/java/com/taobao/top/analysis/node/connect/AbstractMasterConnector.java:15
Class
AbstractNode
抽象节点处理主骨骼结构,当前节点循环执行某一些逻辑,后台也支持监听事件发生 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:29
Class
AbstractSlaveConnector
@author fangweng @email: fangweng@taobao.com 2011-12-2 下午5:22:20
src/java/com/taobao/top/analysis/node/connect/AbstractSlaveConnector.java:16
Class
Alias
报表列别名定义,便于修改列 @author fangweng
src/java/com/taobao/top/analysis/statistics/data/Alias.java:12
Class
AnalysisConstants
报表常量定义 @author fangweng
src/java/com/taobao/top/analysis/util/AnalysisConstants.java:9
Class
AnalysisException
分析包中的异常基类 @author fangweng
src/java/com/taobao/top/analysis/exception/AnalysisException.java:11
Class
AnalyzerFilenameFilter
需要分析的日志文件过滤类,根据后缀名 @author fangweng
src/java/com/taobao/top/analysis/util/AnalyzerFilenameFilter.java:15
Class
AnalyzerUtil
Analyzer中的一些公共方法 AnalyzerUtil.java @author yunzhan.jtq @since 2012-2-8 下午01:30:45
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:39
Class
AnalyzerZKWatcher
简单的监控节点数据变化,将变化的数据设置到config中 @author fangweng email: fangweng@taobao.com 下午1:31:34
src/java/com/taobao/top/analysis/util/AnalyzerZKWatcher.java:21
Class
AvgFunction
直到export的时候才真正执行average操作 @author fangweng email: fangweng@taobao.com 下午11:17:47
src/java/com/taobao/top/analysis/statistics/reduce/group/AvgFunction.java:18
Interface
BloomFilter
bloom过滤器接口定义 @author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:15
Class
BundleTasksExecutable
同一个Job的多个Task并行执行,并最后合并的模式处理 @author fangweng email: fangweng@taobao.com 下午2:00:58
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:756
Class
ByteBloomFilter
@author fangweng @email fangweng@taobao.com @date 2011-3-16 Implements a Bloom filter, as defined by Bloom in 1970. The Bloom filter is a
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:32
Interface
Callback
src/java/com/taobao/top/analysis/HttpAgentNode.java:107
Class
ChartUtil
绘图工具类 @author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:32
Class
CountFunction
src/java/com/taobao/top/analysis/statistics/reduce/group/CountFunction.java:8
Class
CreateReportOperation
创建报表的可执行类,用于异步化执行创建报表操作 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/operation/CreateReportOperation.java:31
Class
DataWriter
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:330
Class
DefaultAnalysisEngineTest
@author fangweng @Email fangweng@taobao.com 2011-11-26 测试整个分析统计抽象层的测试用例子,analysis-job-config.properties中的一个数据来源 需要通过http本地获得数据,因此首先跑这个用例以前先运行TestServ
src/java.test/com/taobao/top/analysis/node/component/DefaultAnalysisEngineTest.java:32
Class
DefaultAnalysisEngineTestBig
@author fangweng @Email fangweng@taobao.com 2011-11-26 测试整个分析统计抽象层的测试用例子,analysis-job-config.properties中的一个数据来源 需要通过http本地获得数据,因此首先跑这个用例以前先运行TestServ
src/java.test/com/taobao/top/analysis/node/component/DefaultAnalysisEngineTestBig.java:32
Class
DefaultMapper
@author zhudi 默认的mapper实现
src/java/com/taobao/top/analysis/statistics/map/DefaultMapper.java:18
Class
DefaultReducer
@author zhudi 默认的实现类
src/java/com/taobao/top/analysis/statistics/reduce/DefaultReducer.java:12
Class
DistinctCountEntryValue
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:17
Class
DistinctCountFunction
@author fangweng email: fangweng@taobao.com 下午4:51:14
src/java/com/taobao/top/analysis/statistics/reduce/group/DistinctCountFunction.java:24
Class
DistinctCountTool
@author fangweng email: fangweng@taobao.com 上午12:19:43
src/java.test/com/taobao/top/analysis/util/bloom/DistinctCountTool.java:22
Class
DistinctEntryTest
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java.test/com/taobao/top/analysis/util/bloom/DistinctEntryTest.java:19
Class
Entry
@author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:254
Class
EntryKey
EntryKey.java @author yunzhan.jtq @since 2012-5-3 下午10:42:43
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:11
Class
ExportTask
导出Master的监控信息到报表
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:479
Class
ExtFilenameFilter
@author zijiang.jl
src/java/com/taobao/top/analysis/util/ExtFilenameFilter.java:14
Class
FileAttr
src/java/com/taobao/top/analysis/HttpAgentNode.java:613
Class
FileComparator
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:320
Class
FileConditionMapper
用于对多个报表字段有&的匹配需求,例如需要appkey在某一个范围并且api也在某一个范围 功能暂时不支持 @author fangweng
src/java/com/taobao/top/analysis/statistics/map/FileConditionMapper.java:22
Class
FileInputAdaptor
文件输入适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/FileInputAdaptor.java:26
Class
FileJobBuilder
通过读取文件,创建多个任务 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:69
Class
FileJobExporter
默认报表输出实现 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:47
Class
FileJobExporterTest
@author fangweng email: fangweng@taobao.com 下午1:13:56
src/java.test/com/taobao/top/analysis/node/component/FileJobExporterTest.java:29
Class
FileOutputAdaptor
文件输出适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/FileOutputAdaptor.java:23
Class
GetTaskRequestEvent
获取任务请求事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:14
Class
GetTaskResponseEvent
获取任务请求的响应事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/GetTaskResponseEvent.java:17
Interface
GroupFunction
组操作方法类 @author zhudi
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunction.java:13
Class
GroupFunctionFactory
组方法工厂 报表Entry统计模式,支持最小,最大,总和,计数,平均,直接显示,去重计数 @author fangweng
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunctionFactory.java:11
Interface
Hash
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/util/bloom/Hash.java:12
Class
HdfsInputAdaptor
@author fangweng email: fangweng@taobao.com 下午1:19:27
src/java/com/taobao/top/analysis/node/io/HdfsInputAdaptor.java:22
Class
HdfsInputAdaptorTest
@author fangweng email: fangweng@taobao.com 下午1:22:35
src/java.test/com/taobao/top/analysis/HdfsInputAdaptorTest.java:23
Class
HdfsOutputAdaptor
@author fangweng email: fangweng@taobao.com 下午2:11:52
src/java/com/taobao/top/analysis/node/io/HdfsOutputAdaptor.java:15
Class
HttpAgentNode
@author zijiang.jl 分布式http节点,提供分析器与外部应用的通道,基于http协议。 1.健康检查 http://url/web?command=check 2.运行时内存数据管理 http://url/web?command=manage&instance=
src/java/com/taobao/top/analysis/HttpAgentNode.java:69
Class
HttpFileHandler
@author sihai
src/java/com/taobao/top/analysis/node/monitor/NHttpServer.java:222
Class
HttpInputAdaptor
Http数据源适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/HttpInputAdaptor.java:25
Class
HubInputAdaptor
HubInputAdaptor.java @author yunzhan.jtq @since 2012-5-16 下午02:11:23
src/java/com/taobao/top/analysis/node/io/HubInputAdaptor.java:26
Interface
ICalculator
src/java/com/taobao/top/analysis/statistics/data/ICalculator.java:5
Interface
IComponent
分析器基础组件接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IComponent.java:16
Interface
ICondition
@author zhudi
src/java/com/taobao/top/analysis/statistics/data/ICondition.java:10
Interface
IConfig
系统配置文件接口 @author fangweng
src/java/com/taobao/top/analysis/config/IConfig.java:10
Interface
IFilter
@author zhudi
src/java/com/taobao/top/analysis/statistics/data/IFilter.java:10
Interface
IInputAdaptor
输入适配器,用于根据任务定义获得数据来源(支持文件,http,hdfs等等随意扩展) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/io/IInputAdaptor.java:19
Interface
IJobBuilder
分析器Master获取任务集的管理接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobBuilder.java:20
Interface
IJobExporter
任务导出管理类,支持任务输出结果报表,载入导出分析中间结果(保存分析现场,支持容灾) @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobExporter.java:20
Interface
IJobManager
任务管理类,是Master的核心类,负责对于整个任务管理流程 注意由于默认的master是单线程执行任务管理,因此要保证jobManager的各个方法都能够快速返回避免影响流程 同时由于单线程管理,对于任务管理和分配的并发控制就可以比较简单处理 @author fangweng @Email fan
src/java/com/taobao/top/analysis/node/IJobManager.java:24
Interface
IJobResultMerger
任务结果合并接口,用于提供不同方式的结果合并 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobResultMerger.java:22
Interface
IMapper
@author zhudi mapper操作,完成从一行数据中产生对 key-value对 @param <T>
src/java/com/taobao/top/analysis/statistics/map/IMapper.java:13
Interface
IMasterConnector
Master端的通信组件,主要用于服务端与客户端通信,可自定义扩展为内存交互,socket交互,db交互等 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:18
Interface
IMonitor
节点监控器 @author sihai
src/java/com/taobao/top/analysis/node/monitor/IMonitor.java:12
Interface
INode
基础节点的接口定义 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/INode.java:17
Interface
INodeEvent
节点的事件接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/event/INodeEvent.java:15
Interface
IOutputAdaptor
支持输出适配的方式来将结果反馈到输出设备(可以是本地文件,远端的Master,HDFS等等,随意扩展) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/io/IOutputAdaptor.java:17
Interface
IReducer
@author zhudi mapper操作生成的key和value会通过调用这个方法聚合 @param <T>
src/java/com/taobao/top/analysis/statistics/reduce/IReducer.java:14
Interface
IReportMap
可定制化的报表Key创建类(Map类) @author fangweng
src/java/com/taobao/top/analysis/node/map/IReportMap.java:19
Interface
IReportReduce
可定制化的value生成类(Reduce类) @author fangweng
src/java/com/taobao/top/analysis/node/reduce/IReportReduce.java:15
Interface
ISlaveConnector
Slave端的通信组件,主要用于服务端与客户端通信,可自定义扩展为内存交互,socket交互,db交互等 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:22
Interface
IStatisticsEngine
每个计算节点的抽象接口,可以植入多种输入适配器,输出适配器 执行任务时,根据输入适配器获得数据来源,然后根据任务自我业务分析规则分析数据, 最后根据输出适配器来输出到外部一个或者多个数据输出点 @author fangweng @Email fangweng@taobao.com 2011-11-
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:27
Class
InnerKey
内部key映射,用于可逆压缩 @author fangweng
src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:24
Class
Inspector
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:174
Class
IspErrorCodeMapper
IspErrorCodeMapper.java @author yunzhan.jtq @since 2012-2-15 下午09:39:39
src/java/com/taobao/top/analysis/statistics/map/IspErrorCodeMapper.java:16
Class
IsvBizErrorCodeMapper
IsvBizErrorCodeMapper.java @author yunzhan.jtq @since 2012-2-15 下午09:51:50
src/java/com/taobao/top/analysis/statistics/map/IsvBizErrorCodeMapper.java:16
Class
IsvSysErrorCodeMapper
IsvSysErrorCodeMapper.java @author yunzhan.jtq @since 2012-4-23 下午04:50:58
src/java/com/taobao/top/analysis/statistics/map/IsvSysErrorCodeMapper.java:16
Class
Job
任务结构体,自我描述了数据来源,数据输出,分析规则,包含的子任务 每个子任务可以被提交到集群的单台机器执行, 可以认为就是每个计算节点所处理无差别任务定义。 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/Job.java:34
Class
JobBuilderTest
@author fangweng email: fangweng@taobao.com 上午11:48:01
src/java.test/com/taobao/top/analysis/node/component/JobBuilderTest.java:23
Class
JobConfig
任务的配置类 @author fangweng
src/java/com/taobao/top/analysis/config/JobConfig.java:15
Class
JobDataOperation
对于某一个Job的数据做操作,支持Job的中间结果导入,导出,删除 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:50
Class
JobExecutionLog
JobTask执行统计日志 @author sihai
src/java/com/taobao/top/analysis/node/monitor/JobExecutionLog.java:9
Class
JobExecutionLogContainer
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:625
Class
JobManageEvent
任务管理类型的事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/JobManageEvent.java:14
Class
JobManager
JobManager会被MasterNode以单线程方式调用 需要注意的是所有的内置Builder,Exporter,ResultMerger,ServerConnector都自己必须保证处理速度 @author fangweng @Email fangweng@taobao.com 2011-1
src/java/com/taobao/top/analysis/node/component/JobManager.java:59
Class
JobManagerTest
src/java.test/com/taobao/top/analysis/node/component/JobManagerTest.java:25
Class
JobMergedResult
用于master合并时获取不到主干的线程临时合并的结果定义 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/job/JobMergedResult.java:15
Class
JobResource
JobResource.java @author yunzhan.jtq @since 2012-2-20 下午01:23:50
src/java/com/taobao/top/analysis/node/job/JobResource.java:21
Class
JobResultMerger
任务合并接口的实现 @author fangweng @Email fangweng@taobao.com 2011-11-30
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:39
Class
JobResultMergerTest
运行时请清除掉output目录下的临时文件,防止干扰 @author fangweng email: fangweng@taobao.com 下午3:41:33
src/java.test/com/taobao/top/analysis/node/component/JobResultMergerTest.java:35
Class
JobTask
任务的真实需要执行的实例,每个计算节点根据描述的输入获取数据, 根据规则来分析数据,最后返回结果到输出 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/JobTask.java:22
Class
JobTaskExecuteInfo
任务执行时必要的执行信息纪录,用于监控和状态报告 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:16
Class
JobTaskExecutionLog
JobTask执行统计日志 @author sihai
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:10
Class
JobTaskResult
任务执行后得到的结果 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:21
Enum
JobTaskStatus
任务执行的状态,用于任务管理和分发(主要在服务端) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/JobTaskStatus.java:15
Class
LineEntry
@author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:269
Class
MapAndParam
保存一个map的实例以及这个map的输入参数 @author zhenzi 2010-12-7 上午07:58:22
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:145
Class
MasterConfig
服务端配置类 @author fangweng
src/java/com/taobao/top/analysis/config/MasterConfig.java:20
Class
MasterConnectorHandler
@author fangweng @email: fangweng@taobao.com 2011-12-5 上午11:44:50
src/java/com/taobao/top/analysis/node/connect/MasterConnectorHandler.java:30
next →
1–100 of 171, ranked by callers