在上一篇 文章 中我们介绍了一些 Flink SQL 的基础内容，以及与 Spark SQL 对比，有兴趣的小伙伴可以点连接进去看看。这篇文章，我们来说说UDF(User-Defined Functions)——用户自定义函数。...

Flink 是一个针对流数据和批数据的分布式处理引擎。说起Flink那么必定会和Spark比一比，从slogan来看也能看出来一些区别（详细内容，可以参考下面链接）：...

https://www.scala-lang.org/download/2.11.12.html

使用maven初始化第一个flink的wordcount应用，将应用打包上传到flink-standalone集群，运行起来。

结合Flink官方文档，整理关于Flink命令行的操作参数，包含命令行接口和Scala Shell

Enumeration应该算是程序语言里面比较通用的一个类型，在scala中也存在这样的类型， 我们看下Enumeration的定义：

Scala中有一个很有用的traits叫PartialFunction，我看了下别人的翻译叫做偏函数，但是我觉得部分函数更加确切。

在scala中可以方便的实现异步操作，这里是通过Future来实现的，和java中的Future很相似，但是功能更加强大。

集合在程序中是非常有用的，只有用好集合才能真正感受到该语言的魅力。在scala中集合主要在三个包里面：scala.collection， scala.collection.immutable和scala.collection.mutable。...

在之前的文章中我们提到了Option，scala中Option表示存在0或者1个元素，如果在处理异常的时候Option就会有很大的限制，因为Option如果返回None，那么我并不知道具体的异常到底是什么，这样scala引入了Either。...