IP属地:陕西
背景 看了网上很多博客的快速排序其实是错误的,例子跑的通,但是遇到一些特殊情况,排序就失效了,花了一点时间研究了下,以文本记录下了,顺便沉淀下。...
Flink 包含3种UDF函数 1、Scalar Functions 标量函数 标量函数,是指返回一个值的函数。标量函数是实现将0,1,或者多个...
背景 最近有业务方提出来生产的kafka的数据需要同步到测试kafka,因为生产kafka集群开了sasl认证,为了保证环境一致,测试kafka...
环境准备 1:jdk安装,防止在/opt/data下,tar –zxf 安装包在/opt/apps下 所有节点都需要 2:sudo apt up...
flink的内存模型和其他流式计算框架的内存模型有所不同。为了减少OOM的发生,flink提供了一种off-heap模式充分利用了direct...
基本概念 1.产生的背景 在经历storm和spark的洗礼之后,首个stateful的流式计算引擎Apache Flink 应运而...