背景 看了网上很多博客的快速排序其实是错误的,例子跑的通,但是遇到一些特殊情况,排序就失效了,花了一点时间研究了下,以文本记录下了,顺便沉淀下。 快速排序:是一个速度很快的交...
背景 看了网上很多博客的快速排序其实是错误的,例子跑的通,但是遇到一些特殊情况,排序就失效了,花了一点时间研究了下,以文本记录下了,顺便沉淀下。 快速排序:是一个速度很快的交...
Flink 包含3种UDF函数 1、Scalar Functions 标量函数 标量函数,是指返回一个值的函数。标量函数是实现将0,1,或者多个标量值转化为一个新值。标量函数...
背景 最近有业务方提出来生产的kafka的数据需要同步到测试kafka,因为生产kafka集群开了sasl认证,为了保证环境一致,测试kafka集群需要具备一下条件 需要和生...
数据产品经理,除了应该具备的如:沟通/原型/文档/项目管理等基本技能外,还应该具有精于“数据”的核心专业技能如【数据认知/数据技术/数据平台/数据分析/搭建指标体系】等,而搭...
0. 前言 Java线程池作为最常使用到的并发工具,大多数同学都有使用的经验,但你确定你是在正确的使用线程池吗?阿里Java代码规范要求我们不使用 Executors来快速创...
HashMap, ConcurrentHashMap 原理及源码,一次性讲清楚! 网上关于 HashMap 和 ConcurrentHashMap 的文章确实不少,不过缺斤少...
本文仅为笔者平日学习记录之用,侵删原文:https://mp.weixin.qq.com/s/dKpYz-YvySAyAEFCq5_dGA 前言 目前实时任务主要以 Flin...
环境准备 1:jdk安装,防止在/opt/data下,tar –zxf 安装包在/opt/apps下 所有节点都需要 2:sudo apt update 源升级,所有节点都需...
flink的内存模型和其他流式计算框架的内存模型有所不同。为了减少OOM的发生,flink提供了一种off-heap模式充分利用了direct内存的优势,在提高吞吐的同时减...
基本概念 1.产生的背景 在经历storm和spark的洗礼之后,首个stateful的流式计算引擎Apache Flink 应运而生。但stateful给用户带...