stream process

76 篇文章
15 人订阅

全部文章

sanmutongzi

记一次kafka客户端NOT_COORDINATOR_FOR_GROUP处理过程

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/10602799.html

8730
sanmutongzi

flink on yarn部分源码解析

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/9403427.html

13130
sanmutongzi

spark-streaming-kafka-0-10源码分析

转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/7767621.html

9610
sanmutongzi

flink-connector-kafka consumer checkpoint源码分析

转发请注明原创地址:http://www.cnblogs.com/dongxiao-yang/p/7700600.html

12720
sanmutongzi

GroupCoordinator joingroup源码解析

转发请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/7463693.html

11920
sanmutongzi

storm RollingTopWords 实时top-N计算任务窗口设计

转发请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/6381037.html

6910
sanmutongzi

PriorityBlockingQueue优先队列的二叉堆实现

转载请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/6293807.html

7410
sanmutongzi

堆排序算法的java实现

堆积排序(Heapsort)是指利用堆积树(堆)这种数据结构所设计的一种排序算法,可以利用数组的特点快速定位指定索引的元素。堆排序是不稳定的排序方法,...

9330
sanmutongzi

kafka consumer 分区reblance算法

转载请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/6238029.html

7220
sanmutongzi

btrace 笔记

转载请注明原链接地址 http://www.cnblogs.com/dongxiao-yang/p/6134393.html

8510
sanmutongzi

【转载】Storm TickTuple 意外停止

原文链接转自:http://woodding2008.iteye.com/blog/2328114

8610
sanmutongzi

【转载】nginx 并发数问题思考:worker_connections,worker_processes与 max clients

注:这个文章主要是作者一直在研究nginx作为http server和反向代理服务器时候所谓最大的max_clients和 worker_connections...

9010
sanmutongzi

【转载】运维小技巧:使用ss命令代替 netstat

顾名思义,ss命令可以用来获取socket统计信息,它可以显示和netstat类似的内容。但ss的优势在于它能够显示更多更详细的有关TCP和连接状态的信息,而且...

10710
sanmutongzi

zookeeper 删除snapshot和transaction log的源码解读

转载请注明源地址http://www.cnblogs.com/dongxiao-yang/p/4910059.html

8920
sanmutongzi

为什么要使用SLF4J而不是Log4J

本文由 ImportNew - Jaskey 翻译自 javarevisited。欢迎加入翻译小组。转载请见文末要求。

9230
sanmutongzi

Hive 创建和生成Rcfile 和SequenceFile格式的表

rcfile格式表需要从原始的textfile 文件格式表导出数据并导入到新建好的rcfile格式表里

12020
sanmutongzi

sparkstreaming的状态计算-updateStateByKey源码

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/11358781.html

8510
sanmutongzi

java.util.concurrent 包笔记 --- BlockingQueue

队列接口,具有 4 组不同的方法用于插入、移除以及对队列中的元素进行检查。如果请求的操作不能得到立即执行的话,每个方法的表现也不同。这些方法如下:

7720
sanmutongzi

kafka default partitioner java版本和scala版本的不同

8810
sanmutongzi

kafka rebalance 部分分区没有owner

转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/6234673.html

9120

扫码关注云+社区

领取腾讯云代金券