Flink-1.9流计算开发:十四、union函数
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十四、union函数》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十四篇。通过简单的DEMO来演示union函数执行的效果 。[......]
专注于保护地球的程序员,已成为老父亲的90后
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十四、union函数》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十四篇。通过简单的DEMO来演示union函数执行的效果 。[......]
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十三、min、minBy、max、maxBy函数》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十三篇。通过简单的DEMO来演示apply函数执行的效果 。[......]
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十二、apply函数》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十一篇。通过简单的DEMO来演示apply函数执行的效果 。[......]
如果只是做数据备份的话,直接搭建一个replica set集群或者shard集群就可以实现目的了。但这样的话作为备份库的节点都是secondery,你没法往备份库上写数据上去。
不幸的是我最近就遇到了这样的需求,一个云上mongodb和一个云下机房的mongodb。云上的数据需要实时同步到云下,但云下的数据库会写入一些其它业务。
这样的话我只能将数据实时从云上采集到云下库。
本文介绍的是基于kafka-connector的一种解决方案。
[......]
最近开发时,经常要搭建一些开发环境,记录一下kafka集群搭建的过程,方便日后快速搭建出可以作为开发使用的kafka集群。[......]
1、使用jad-gui。这对于少量代码是可行的,通常来讲一个jar[......]
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十一、count-window-Sliding》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十一篇。通过简单的DEMO来演示count-window-Sliding时间窗口函数执行的效果 。[......]
Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十、count-window-tumbling》[cosmozhu](https://www.cosmozhu.fun)写的本系列文章的第十篇。通过简单的DEMO来演示time-window-tumbling时间窗口函数执行的效果 。[......]
现在的项目中应该基本都用redis做缓存了,本文提供一个简单的线程安全缓存类,提供超时淘汰策略。方便没必要引进第三方缓存时使用。[......]
在目前的spring家族中,bean的默认生命周期就是单例模式,使用起来极为简单。但是脱离了spring框架后,如果需要一个单例还是需要自己实现的,单例模式一共有5种且分两类:饿汉式和懒汉式。这里只提供两种工业上常用的实现方式。[......]