flink

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