flink
0
推荐
9286
浏览
Flink-流拆分和流合并
如果我们有一个kafka-topic写了不同的数据,我们需要根据这个输入数据进行不同的处理逻辑,但是最终结果需要合并在一个流里面,那么这个时候即可用这么一波操作。1、使用split方法进行数据分流,把分流信息存到新...
brucelu 发表了文章 • 2019-01-23 16:21
0
推荐
2005
浏览
Flink-基础计数wordcount
flink最简单的程序就是wordcount,即对单词进行计次计算。flink分流处理和批处理,流处理调用DataStream-api进行处理,批处理调用DataSet-api进行处理,DataSet、DataStream都是是flink底层的api。一、流式处理:...
brucelu 发表了文章 • 2019-01-22 16:55
0
推荐
2598
浏览
Flink开发前基础准备
一、基础开发环境准备:idea、maven、kafka本地环境安装配置好了即可。idea配置pom.xml文件,flink的主要依赖包加上 <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java --...
brucelu 发表了文章 • 2019-01-18 15:48
1
推荐
2884
浏览
flink基础环境配置
基础机器配置:MacBook Pro 其他机器可以搞个linux的虚拟机也一样。1、下载flink安装文件:路径:https://flink.apache.org/downloads.html一种是下载与hadoop匹配的版本,一种是下载纯净的flink版本,下面的是ha...
brucelu 发表了文章 • 2018-09-15 23:03
0
推荐
9286
浏览
Flink-流拆分和流合并
如果我们有一个kafka-topic写了不同的数据,我们需要根据这个输入数据进行不同的处理逻辑,但是最终结果需要合并在一个流里面,那么这个时候即可用这么一波操作。1、使用split方法进行数据分流,把分流信息存到新...
brucelu 发表了文章 • 2019-01-23 16:21
0
推荐
2005
浏览
Flink-基础计数wordcount
flink最简单的程序就是wordcount,即对单词进行计次计算。flink分流处理和批处理,流处理调用DataStream-api进行处理,批处理调用DataSet-api进行处理,DataSet、DataStream都是是flink底层的api。一、流式处理:...
brucelu 发表了文章 • 2019-01-22 16:55
0
推荐
2598
浏览
Flink开发前基础准备
一、基础开发环境准备:idea、maven、kafka本地环境安装配置好了即可。idea配置pom.xml文件,flink的主要依赖包加上 <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java --...
brucelu 发表了文章 • 2019-01-18 15:48
1
推荐
2884
浏览
flink基础环境配置
基础机器配置:MacBook Pro 其他机器可以搞个linux的虚拟机也一样。1、下载flink安装文件:路径:https://flink.apache.org/downloads.html一种是下载与hadoop匹配的版本,一种是下载纯净的flink版本,下面的是ha...
brucelu 发表了文章 • 2018-09-15 23:03