MCPcopy Create free account

hub / github.com/cenwenchu/beatles / types & classes

Types & classes171 in github.com/cenwenchu/beatles

ClassAbstractConfig
配置抽象类 参数采取动态获取,每次获取都会可能产生消耗,注意使用场景 @author fangweng
src/java/com/taobao/top/analysis/config/AbstractConfig.java:27
ClassAbstractMapper
通过final限制mapper的流程 @author zhudi
src/java/com/taobao/top/analysis/statistics/map/AbstractMapper.java:16
ClassAbstractMasterConnector
@author fangweng @email: fangweng@taobao.com 2011-12-2 下午5:17:39
src/java/com/taobao/top/analysis/node/connect/AbstractMasterConnector.java:15
ClassAbstractNode
抽象节点处理主骨骼结构,当前节点循环执行某一些逻辑,后台也支持监听事件发生 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:29
ClassAbstractSlaveConnector
@author fangweng @email: fangweng@taobao.com 2011-12-2 下午5:22:20
src/java/com/taobao/top/analysis/node/connect/AbstractSlaveConnector.java:16
ClassAlias
报表列别名定义,便于修改列 @author fangweng
src/java/com/taobao/top/analysis/statistics/data/Alias.java:12
ClassAnalysisConstants
报表常量定义 @author fangweng
src/java/com/taobao/top/analysis/util/AnalysisConstants.java:9
ClassAnalysisException
分析包中的异常基类 @author fangweng
src/java/com/taobao/top/analysis/exception/AnalysisException.java:11
ClassAnalyzerFilenameFilter
需要分析的日志文件过滤类,根据后缀名 @author fangweng
src/java/com/taobao/top/analysis/util/AnalyzerFilenameFilter.java:15
ClassAnalyzerUtil
Analyzer中的一些公共方法 AnalyzerUtil.java @author yunzhan.jtq @since 2012-2-8 下午01:30:45
src/java/com/taobao/top/analysis/util/AnalyzerUtil.java:39
ClassAnalyzerZKWatcher
简单的监控节点数据变化,将变化的数据设置到config中 @author fangweng email: fangweng@taobao.com 下午1:31:34
src/java/com/taobao/top/analysis/util/AnalyzerZKWatcher.java:21
ClassAvgFunction
直到export的时候才真正执行average操作 @author fangweng email: fangweng@taobao.com 下午11:17:47
src/java/com/taobao/top/analysis/statistics/reduce/group/AvgFunction.java:18
InterfaceBloomFilter
bloom过滤器接口定义 @author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/util/bloom/BloomFilter.java:15
ClassBundleTasksExecutable
同一个Job的多个Task并行执行,并最后合并的模式处理 @author fangweng email: fangweng@taobao.com 下午2:00:58
src/java/com/taobao/top/analysis/node/component/SlaveNode.java:756
ClassByteBloomFilter
@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
InterfaceCallback
src/java/com/taobao/top/analysis/HttpAgentNode.java:107
ClassChartUtil
绘图工具类 @author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:32
ClassCountFunction
src/java/com/taobao/top/analysis/statistics/reduce/group/CountFunction.java:8
ClassCreateReportOperation
创建报表的可执行类,用于异步化执行创建报表操作 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/operation/CreateReportOperation.java:31
ClassDataWriter
src/java/com/taobao/top/analysis/util/bloom/ByteBloomFilter.java:330
ClassDefaultAnalysisEngineTest
@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
ClassDefaultAnalysisEngineTestBig
@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
ClassDefaultMapper
@author zhudi 默认的mapper实现
src/java/com/taobao/top/analysis/statistics/map/DefaultMapper.java:18
ClassDefaultReducer
@author zhudi 默认的实现类
src/java/com/taobao/top/analysis/statistics/reduce/DefaultReducer.java:12
ClassDistinctCountEntryValue
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/statistics/data/DistinctCountEntryValue.java:17
ClassDistinctCountFunction
@author fangweng email: fangweng@taobao.com 下午4:51:14
src/java/com/taobao/top/analysis/statistics/reduce/group/DistinctCountFunction.java:24
ClassDistinctCountTool
@author fangweng email: fangweng@taobao.com 上午12:19:43
src/java.test/com/taobao/top/analysis/util/bloom/DistinctCountTool.java:22
ClassDistinctEntryTest
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java.test/com/taobao/top/analysis/util/bloom/DistinctEntryTest.java:19
ClassEntry
@author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:254
ClassEntryKey
EntryKey.java @author yunzhan.jtq @since 2012-5-3 下午10:42:43
src/java/com/taobao/top/analysis/statistics/data/EntryKey.java:11
ClassExportTask
导出Master的监控信息到报表
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:479
ClassExtFilenameFilter
@author zijiang.jl
src/java/com/taobao/top/analysis/util/ExtFilenameFilter.java:14
ClassFileAttr
src/java/com/taobao/top/analysis/HttpAgentNode.java:613
ClassFileComparator
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:320
ClassFileConditionMapper
用于对多个报表字段有&的匹配需求,例如需要appkey在某一个范围并且api也在某一个范围 功能暂时不支持 @author fangweng
src/java/com/taobao/top/analysis/statistics/map/FileConditionMapper.java:22
ClassFileInputAdaptor
文件输入适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/FileInputAdaptor.java:26
ClassFileJobBuilder
通过读取文件,创建多个任务 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/component/FileJobBuilder.java:69
ClassFileJobExporter
默认报表输出实现 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/component/FileJobExporter.java:47
ClassFileJobExporterTest
@author fangweng email: fangweng@taobao.com 下午1:13:56
src/java.test/com/taobao/top/analysis/node/component/FileJobExporterTest.java:29
ClassFileOutputAdaptor
文件输出适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/FileOutputAdaptor.java:23
ClassGetTaskRequestEvent
获取任务请求事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/GetTaskRequestEvent.java:14
ClassGetTaskResponseEvent
获取任务请求的响应事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/GetTaskResponseEvent.java:17
InterfaceGroupFunction
组操作方法类 @author zhudi
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunction.java:13
ClassGroupFunctionFactory
组方法工厂 报表Entry统计模式,支持最小,最大,总和,计数,平均,直接显示,去重计数 @author fangweng
src/java/com/taobao/top/analysis/statistics/reduce/group/GroupFunctionFactory.java:11
InterfaceHash
@author fangweng @email fangweng@taobao.com @date 2011-3-16
src/java/com/taobao/top/analysis/util/bloom/Hash.java:12
ClassHdfsInputAdaptor
@author fangweng email: fangweng@taobao.com 下午1:19:27
src/java/com/taobao/top/analysis/node/io/HdfsInputAdaptor.java:22
ClassHdfsInputAdaptorTest
@author fangweng email: fangweng@taobao.com 下午1:22:35
src/java.test/com/taobao/top/analysis/HdfsInputAdaptorTest.java:23
ClassHdfsOutputAdaptor
@author fangweng email: fangweng@taobao.com 下午2:11:52
src/java/com/taobao/top/analysis/node/io/HdfsOutputAdaptor.java:15
ClassHttpAgentNode
@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
ClassHttpFileHandler
@author sihai
src/java/com/taobao/top/analysis/node/monitor/NHttpServer.java:222
ClassHttpInputAdaptor
Http数据源适配器 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/io/HttpInputAdaptor.java:25
ClassHubInputAdaptor
HubInputAdaptor.java @author yunzhan.jtq @since 2012-5-16 下午02:11:23
src/java/com/taobao/top/analysis/node/io/HubInputAdaptor.java:26
InterfaceICalculator
src/java/com/taobao/top/analysis/statistics/data/ICalculator.java:5
InterfaceIComponent
分析器基础组件接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IComponent.java:16
InterfaceICondition
@author zhudi
src/java/com/taobao/top/analysis/statistics/data/ICondition.java:10
InterfaceIConfig
系统配置文件接口 @author fangweng
src/java/com/taobao/top/analysis/config/IConfig.java:10
InterfaceIFilter
@author zhudi
src/java/com/taobao/top/analysis/statistics/data/IFilter.java:10
InterfaceIInputAdaptor
输入适配器,用于根据任务定义获得数据来源(支持文件,http,hdfs等等随意扩展) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/io/IInputAdaptor.java:19
InterfaceIJobBuilder
分析器Master获取任务集的管理接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobBuilder.java:20
InterfaceIJobExporter
任务导出管理类,支持任务输出结果报表,载入导出分析中间结果(保存分析现场,支持容灾) @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobExporter.java:20
InterfaceIJobManager
任务管理类,是Master的核心类,负责对于整个任务管理流程 注意由于默认的master是单线程执行任务管理,因此要保证jobManager的各个方法都能够快速返回避免影响流程 同时由于单线程管理,对于任务管理和分配的并发控制就可以比较简单处理 @author fangweng @Email fan
src/java/com/taobao/top/analysis/node/IJobManager.java:24
InterfaceIJobResultMerger
任务结果合并接口,用于提供不同方式的结果合并 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/IJobResultMerger.java:22
InterfaceIMapper
@author zhudi mapper操作,完成从一行数据中产生对 key-value对 @param <T>
src/java/com/taobao/top/analysis/statistics/map/IMapper.java:13
InterfaceIMasterConnector
Master端的通信组件,主要用于服务端与客户端通信,可自定义扩展为内存交互,socket交互,db交互等 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/connect/IMasterConnector.java:18
InterfaceIMonitor
节点监控器 @author sihai
src/java/com/taobao/top/analysis/node/monitor/IMonitor.java:12
InterfaceINode
基础节点的接口定义 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/INode.java:17
InterfaceINodeEvent
节点的事件接口 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/event/INodeEvent.java:15
InterfaceIOutputAdaptor
支持输出适配的方式来将结果反馈到输出设备(可以是本地文件,远端的Master,HDFS等等,随意扩展) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/io/IOutputAdaptor.java:17
InterfaceIReducer
@author zhudi mapper操作生成的key和value会通过调用这个方法聚合 @param <T>
src/java/com/taobao/top/analysis/statistics/reduce/IReducer.java:14
InterfaceIReportMap
可定制化的报表Key创建类(Map类) @author fangweng
src/java/com/taobao/top/analysis/node/map/IReportMap.java:19
InterfaceIReportReduce
可定制化的value生成类(Reduce类) @author fangweng
src/java/com/taobao/top/analysis/node/reduce/IReportReduce.java:15
InterfaceISlaveConnector
Slave端的通信组件,主要用于服务端与客户端通信,可自定义扩展为内存交互,socket交互,db交互等 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/connect/ISlaveConnector.java:22
InterfaceIStatisticsEngine
每个计算节点的抽象接口,可以植入多种输入适配器,输出适配器 执行任务时,根据输入适配器获得数据来源,然后根据任务自我业务分析规则分析数据, 最后根据输出适配器来输出到外部一个或者多个数据输出点 @author fangweng @Email fangweng@taobao.com 2011-11-
src/java/com/taobao/top/analysis/statistics/IStatisticsEngine.java:27
ClassInnerKey
内部key映射,用于可逆压缩 @author fangweng
src/java/com/taobao/top/analysis/statistics/data/InnerKey.java:24
ClassInspector
src/java/com/taobao/top/analysis/node/component/AbstractNode.java:174
ClassIspErrorCodeMapper
IspErrorCodeMapper.java @author yunzhan.jtq @since 2012-2-15 下午09:39:39
src/java/com/taobao/top/analysis/statistics/map/IspErrorCodeMapper.java:16
ClassIsvBizErrorCodeMapper
IsvBizErrorCodeMapper.java @author yunzhan.jtq @since 2012-2-15 下午09:51:50
src/java/com/taobao/top/analysis/statistics/map/IsvBizErrorCodeMapper.java:16
ClassIsvSysErrorCodeMapper
IsvSysErrorCodeMapper.java @author yunzhan.jtq @since 2012-4-23 下午04:50:58
src/java/com/taobao/top/analysis/statistics/map/IsvSysErrorCodeMapper.java:16
ClassJob
任务结构体,自我描述了数据来源,数据输出,分析规则,包含的子任务 每个子任务可以被提交到集群的单台机器执行, 可以认为就是每个计算节点所处理无差别任务定义。 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/Job.java:34
ClassJobBuilderTest
@author fangweng email: fangweng@taobao.com 上午11:48:01
src/java.test/com/taobao/top/analysis/node/component/JobBuilderTest.java:23
ClassJobConfig
任务的配置类 @author fangweng
src/java/com/taobao/top/analysis/config/JobConfig.java:15
ClassJobDataOperation
对于某一个Job的数据做操作,支持Job的中间结果导入,导出,删除 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/operation/JobDataOperation.java:50
ClassJobExecutionLog
JobTask执行统计日志 @author sihai
src/java/com/taobao/top/analysis/node/monitor/JobExecutionLog.java:9
ClassJobExecutionLogContainer
src/java/com/taobao/top/analysis/node/component/MasterMonitor.java:625
ClassJobManageEvent
任务管理类型的事件 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/event/JobManageEvent.java:14
ClassJobManager
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
ClassJobManagerTest
src/java.test/com/taobao/top/analysis/node/component/JobManagerTest.java:25
ClassJobMergedResult
用于master合并时获取不到主干的线程临时合并的结果定义 @author fangweng @Email fangweng@taobao.com 2011-11-28
src/java/com/taobao/top/analysis/node/job/JobMergedResult.java:15
ClassJobResource
JobResource.java @author yunzhan.jtq @since 2012-2-20 下午01:23:50
src/java/com/taobao/top/analysis/node/job/JobResource.java:21
ClassJobResultMerger
任务合并接口的实现 @author fangweng @Email fangweng@taobao.com 2011-11-30
src/java/com/taobao/top/analysis/node/component/JobResultMerger.java:39
ClassJobResultMergerTest
运行时请清除掉output目录下的临时文件,防止干扰 @author fangweng email: fangweng@taobao.com 下午3:41:33
src/java.test/com/taobao/top/analysis/node/component/JobResultMergerTest.java:35
ClassJobTask
任务的真实需要执行的实例,每个计算节点根据描述的输入获取数据, 根据规则来分析数据,最后返回结果到输出 @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/JobTask.java:22
ClassJobTaskExecuteInfo
任务执行时必要的执行信息纪录,用于监控和状态报告 @author fangweng @Email fangweng@taobao.com 2011-11-25
src/java/com/taobao/top/analysis/node/job/JobTaskExecuteInfo.java:16
ClassJobTaskExecutionLog
JobTask执行统计日志 @author sihai
src/java/com/taobao/top/analysis/node/monitor/JobTaskExecutionLog.java:10
ClassJobTaskResult
任务执行后得到的结果 @author fangweng @Email fangweng@taobao.com 2011-11-29
src/java/com/taobao/top/analysis/node/job/JobTaskResult.java:21
EnumJobTaskStatus
任务执行的状态,用于任务管理和分发(主要在服务端) @author fangweng @Email fangweng@taobao.com 2011-11-24
src/java/com/taobao/top/analysis/node/job/JobTaskStatus.java:15
ClassLineEntry
@author sihai
src/java/com/taobao/top/analysis/util/ChartUtil.java:269
ClassMapAndParam
保存一个map的实例以及这个map的输入参数 @author zhenzi 2010-12-7 上午07:58:22
src/java/com/taobao/top/analysis/statistics/map/MultiConditionMapper.java:145
ClassMasterConfig
服务端配置类 @author fangweng
src/java/com/taobao/top/analysis/config/MasterConfig.java:20
ClassMasterConnectorHandler
@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