把hive 表stu77 的数据写入 mysql 表test_stu 中. 中间可以加自己的逻辑. ...

Flink批处理与hbase的读写 source-hbase 父类 是模仿官方写的. 子类 sink-hbase ...

AdPojo{channel='朋友圈', subject='英语', refer='H5', reg='100', ord='100', pv='100', uv='100'} ...

一、DataSet API之Data Sources（消费者之数据源） 介绍： flink提供了大量的已经实现好的source方法，你也可以自定义source 通过实现sourceFunction接口来自定义无并行度的source， 或者你也可以通过实现 ...

一、环境准备 本机环境：jdk11、scala2.12、maven3.6 新建一个maven项目，pom如下 项目结构如下 1、添加scala源文件，新建一个scala的文件夹， ...

一、写数据 　　向Hive中写数据只尝试了流数据写入Hive，毕竟批数据写入数仓的场景并不多，Flink 1.11对于Hive流处理的支持还是改善很多的，用起来也很方便。 　　1、可以直接将流数据转换为Table写入hive（测试环境下采用文件写入DataStream，再转换为Table ...

-----------更新说明---------- 突然就想水一篇博客，刚好说明一下这段时间基本没有更新的问题。 简单介绍下我的职业生涯，大家有留意的话，可以在博客园上看到，我的博客是从20 ...

一、flink在批处理中常见的source 　　flink在批处理中常见的source主要有两大类: 　 　　　　1.基于本地集合的source（Collection-based-source） 　　 　　　　2.基于文件的source（File-based-source ...