以flink处理kafka消息流场景为例，将接受到的kafka消息sink到mysql、elastic、hdfs、kafka，通过真实的案例，助你入门flink计算框架。课程案例代码也可移植到其它业务系统，实现快速开发。
2022-02-07 14:56:39
287.37MB
1
eclispse mars2 4.5对应的PyDev5.2.0python插件，不需要C币的
2022-02-06 10:35:00
26.55MB
1
简单的学生信息管理系统，实现对用户类型的不同权限管理(增删改查).
2022-01-29 09:03:43
951KB
1
已对doris 0.15版本中的apache_hdfs_broker组件进行了编译，可以直接使用此包进行 分发，修改配置文件，启动（之前需要对doris进行安装启动）
***
对应的doris0.15安装包链接如下：https://download.csdn.net/download/yang_shibiao/77998892
***
如果需要积分或者校验码，可以去百度网盘中下载，地址如下：链接：https://pan.baidu.com/s/1UOQSc35qlUjQgvmfareMhQ 提取码：1234
2022-01-28 14:00:47
49.06MB
1
yarn-auditlog-parser
Yarn的hdfs-audit.log的日志文件解析，从ip,用户名，时间段维度对hdfs的qps量进行统计
原理介绍
此工具用于分析hdfs-audit日志文件中的hdfs请求,比如下面是一条完整的记录
2015-09-09 05:29:54,727 INFO FSNamesystem.audit: allowed=true ugi=data (auth:SIMPLE) ip=/192.128.10.15 cmd=open
src=/user/data/.staging/job_1441718170682_2949/job.jar dst=null perm=null proto=rpc
解析程序主要抽取出其中的时间,ugi用户信息,ip地址信息,cmd操作命令信息,然后进行各个维度统计.
下面是几种使用方法
1.用户分时段统计
java -j
2022-01-28 10:10:05
7KB
1