Flink-1.9流计算开发:十六、intervalJoin函数

flink intervalJoin,Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十六、intervalJoin函数》[cosmozhu](http://www.cosmozhu.fun)写的本系列文章的第十六篇。通过简单的DEMO来演示flink intervalJoin函数执行的效果 。[......]

继续阅读

Flink-1.9流计算开发:十五、join函数

flink join,Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十五、join函数》cosmozhu写的本系列文章的第十五篇。通过简单的DEMO来演示join函数执行的效果 。

需求

当前有一个订单流(每秒1个订单),一个人民币-美元汇率流(每10秒发[......]

继续阅读

Flink-1.9流计算开发:十四、union函数

Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十四、union函数》[cosmozhu](http://www.cosmozhu.fun)写的本系列文章的第十四篇。通过简单的DEMO来演示union函数执行的效果 。[......]

继续阅读

Flink-1.9流计算开发:十二、apply函数

Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十二、apply函数》[cosmozhu](http://www.cosmozhu.fun)写的本系列文章的第十一篇。通过简单的DEMO来演示apply函数执行的效果 。[......]

继续阅读

mongodb:实时数据同步(一)

如果只是做数据备份的话,直接搭建一个replica set集群或者shard集群就可以实现目的了。但这样的话作为备份库的节点都是secondery,你没法往备份库上写数据上去。
不幸的是我最近就遇到了这样的需求,一个云上mongodb和一个云下机房的mongodb。云上的数据需要实时同步到云下,但云下的数据库会写入一些其它业务。
这样的话我只能将数据实时从云上采集到云下库。
本文介绍的是基于kafka-connector的一种解决方案。
[......]

继续阅读

Kafka集群搭建

最近开发时,经常要搭建一些开发环境,记录一下kafka集群搭建的过程,方便日后快速搭建出可以作为开发使用的kafka集群。[......]

继续阅读

用jad做一个快乐的java代码阅读师

对于我们大多数java代码的开发者,阅读已经编译好的class文件是我们经常要做的事情。最常见的方法无外乎使用IDE(eclipse、idea)自带的反编译功能。那如果在没有源码的情况下需要对class文件批量反编译需要如何做呢?

1、使用jad-gui。这对于少量代码是可行的,通常来讲一个jar[......]

继续阅读

微信扫码关注cosmozhu

cosmozhu微信公众号
【腾讯云】云产品限时秒杀,爆款1核2G云服务器,首年99元

近期文章

分类目录

功能