windows环境下flink入门demo实例
Apache Flink是什么？ Apache Flink 是一个分布式大数据处理引擎，可对有限数据流和无限数据流进行有状态计算。可部署在各种集群环境，对各种大小的数据规模进行快速计算。上面是非常官方的描述，说白了我们为什么选择Flink，是因为他在社区口碑非常不错。在国内的话有阿里这种大数据 ...
原文：Flink Java Demo（Windows）
关于Flink相关的概念性东西就不说了，网上都有，官网也很详尽。本文主要记录一下Java使用Flink的简单例子。 首先，去官网下载Flink的zip包 链接就不提供了，你已经是个成熟的程序员了，该有一定的搜索能力了 ，解压后放到你想放的地方。 进入主目录后，是这样子的 image.png 你可以简单的看下其目录结构，然后就回到你喜欢的IDE创建一个工程吧。 使用IDEA创建一个maven项目， ...
2019-02-14 19:39 0 4952 推荐指数：
相关推荐
FLink Table API JAVA_BATCH_DEMO
<dependencies> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-api-java ...
flink系列-7、窗口函数 & Windows 的 Operator demo
代码地址：https://gitee.com/xiexiandong/abc_bigdata.git 一、窗口函数 在定义了窗口分配器之后，我们需要为每一个窗口明确的指定计算逻辑，这个就是窗 ...
Flink广播流Demo
广播状态 从版本1.5.0开始，Apache Flink具有一种新的状态，称为广播状态。 三种应用场景 动态配置更新 规则改变 类似开关的功能 假设场景， 有两条流，一条是普通的流，另一条是控制流，如果需要动态调整代码逻辑时，可以使用广播状态 ...
flink cdc demo
Flink 1.11 发布了支持 MySQL CDC（Changelog Data Capture） 可以直接解析 Canal / Debezium 格式的 MySQL Binlog 对于实时处理程序，MySQL 的 Binlog 是很重要的数据源（上一个项目几乎所有实时数据都是来自业务系统 ...
Flink的WaterMark，及demo实例
实际生产中，由于各种原因，导致事件创建时间与处理时间不一致，收集的规定对实时推荐有较大的影响。所以一般情况时选取创建时间，然后事先创建flink的时间窗口。但是问题来了，如何保证这个窗口的时间内所有事件都到齐了？这个时候就可以设置水位线（waterMark）。 概念：支持基于时间 ...
Flink 反馈流 Demo
有的时候，我们需要创建有环执行流图，比如将一些处理过后还不满足条件的数据，返回到最开始重新处理。 之前在做的时候，会考虑将处理后还不满足的数据，写入到单独的 Topic 中重新消费处理 今天发现 Flink Iterate 算子，发现也能满足需求 官网介绍： https ...
flink sql join hbase demo
lookup join mysql demo： flink lookup join mysql demo ## join rowkey 测试 hbase 维表Lookup 功能正常，可以正常缓存数据，缓存也会定时失效，透查Hbase * 注： 随便测试了一下 ...