前言 流应用程序的一个常见要求是，为了增大或较小输入数据的速率，需要灵活地调整算子的并行度。对于无状态算子而言，并行度的调整没有任何问题，但更改有状态算子的并行度显然就没那么...
发简信
IP属地：山东
-
Flink rescale state 调整有状态算子的并行度 -
聊聊flink的CheckpointedFunction
序 本文主要研究一下flink的CheckpointedFunction 实例 这个BufferingSink实现了CheckpointedFunction接口，它定义了Li...
-
3. kafka开启JMX开启JMX kafka开启JMX的2种方式： 启动kafka时增加JMX_PORT=9988，即JMX_PORT=9988 bin/kafka-server-start.sh...
-
-
-
数据库高并发解决方法总结
一个项目刚开始的时候是为了实现基本功能，随着版本和功能的迭代，大数据和高并发成了软件设计必须考虑的问题! 本质很简单，一个是慢，一个是等。 两者是相互关联的，因为慢，所以要等...
-
(203)线程池原理程序运行，其本质上，是对系统资源（CPU、内存、磁盘、网络等等）的使用。如何高效的使用这些资源是我们编程优化演进的一个方向。今天说的线程池是对CPU的利用的优化手段。 网上有...
-
Mysql InnoDB索引原理Mysql InnoDB索引原理 理解Mysql索引的原理和数据结构有助于我们更好的使用索引以及进行SQL优化，索引是在存储引擎层面实现的，所以不同的引擎实现的索引也有一定的...
-
How to set up a sparklyr cluster in 5 minutes如果您曾经想要使用Sparklyr软件包在R群集中使用Spark集群来处理大数据集，但还没有开始，因为设置Spark集群太难了，好吧......很容易。您可以使用Azure上...
