240 发简信
IP属地:甘肃
  • 快速排序

    背景 看了网上很多博客的快速排序其实是错误的,例子跑的通,但是遇到一些特殊情况,排序就失效了,花了一点时间研究了下,以文本记录下了,顺便沉淀下。...

  • Flink SQL UDF 实现 Demo

    Flink 包含3种UDF函数 1、Scalar Functions 标量函数 标量函数,是指返回一个值的函数。标量函数是实现将0,1,或者多个...

  • 开sasl的kafka测试环境搭建

    背景 最近有业务方提出来生产的kafka的数据需要同步到测试kafka,因为生产kafka集群开了sasl认证,为了保证环境一致,测试kafka...

  • Resize,w 360,h 240
    基于ambari hadoop平台的搭建

    环境准备 1:jdk安装,防止在/opt/data下,tar –zxf 安装包在/opt/apps下 所有节点都需要 2:sudo apt up...

  • 内存模型

    flink的内存模型和其他流式计算框架的内存模型有所不同。为了减少OOM的发生,flink提供了一种off-heap模式充分利用了direct...

  • Resize,w 360,h 240
    checkpoint深入理解

    基本概念 1.产生的背景 在经历storm和spark的洗礼之后,首个stateful的流式计算引擎Apache Flink 应运而...