Flink实战学习（十八）DataStream API的专用转换算子有哪些？
在上一篇文章我们介绍了DataSet API的专用转换算子，这篇文章我们介绍下DataStream API的专用转换算子。一、多流转换算子1.1、Union算子Union算子可以将两个或多个数据流进行合并，从而创建一...
Rae
Flink实战学习（十七）DataSet API的专用转换算子有哪些？
上一篇我们介绍了4个通用性的转换算子，这篇文章我们介绍下flink的DataSet API模型里面，有哪些专用的转换算子。一、聚合类的转换算子1.1、Reduce算子reduce算子主要是将两个元素合并成为一个元素，...
Flink实战学习（十六）DataStream和DataSet的通用算子有哪些？
在flink中，当我们处理有界数据和无界数据的时候，我们读取了数据源之后就需要进行tranform操作。在transform里面，我们转换过程中的各种操作类型被称为算子。然后不同的转换组合成一个复杂的数据流拓扑。下面...
Flink实战学习（十五）Flink支持哪些数据类型
在flink里面，所有的算子计算都是根据对应的数据结构进行计算的。这篇文章我们就介绍下flink支持哪些数据类型。一、元组类型元组类其实就是flink里面所有的Tuple，他是一个不好喊固定数量的各种类型的字段的复合...
Flink实战学习（十四）Flink的累加器和计数器
我们有时候会涉及到数据统计，例如用户给了我们一批数据，没法很直观的看到有多少数据量，那么我们在处理的时候，我们需要统计下具体处理了多少数据量等，那么这个情况下我们就需要进行计数。在flink中，天生提供了一些累加器和...
Flink实战学习（十三）Flink开发自定义函数的方式有哪些？
在flink开发中，我们常常会自定义函数方法或函数类进行数据转换操作。这篇文章就给大家介绍下flink自定义函数的方式有哪些？一、使用flink提供的接口来实现自定义功能在flink中有很多接口，我们只需要实现自定义...
Flink实战学习（十二）Flink开发如何使用ParameterTool
在flink的job开发里面，ParameterTool是一个使用频率比较高的工具类，这个工具类其实就是一个配置的map。在flink job里面，我们自定义的很多类都需要依赖外部传递参数，这时候，在自定义的类里面我...
Flink实战学习（十一）Flink开发如何添加sink
在flink的job开发过程中，我们整体会经历三个阶段，分别是：source -> Transform -> sink。今天我们就来介绍下这个...
Flink实战学习（十）Flink开发如何进行数据转换
在flink的job开发过程中，我们整体会经历三个阶段，分别是：source -> Transform -> sink。今天我们就来介绍下这个Transform，即数据转换。...
Flink实战学习（九）Flink开发如何添加数据源
在flink的job开发过程中，我们整体会经历三个阶段，分别是：source -> Transform -> sink。今天我们就来介绍下这个source。在flink开发里面，不管是DataSet还是D...
