Scala API 扩展
Flink为了保持Java和Scala API的一致性，缩减了一些Scala中比较抽象的高级特性API。
如果想使用Scala的完整API的话，可以通过隐式转换。
DataSet API：
import org.apache.flink.api.scala.extensions._
DataStream API：
import org.apache.flink.streaming.api.scala.extensions._
允许使用部分函数
通常，DataSet和DataStream API都不接受匿名模式匹配函数来解构元组、case类或集合，如下所示：
val data: DataSet[(Int, String, Double)] = // [...]
data.map {
case (id, name, temperature) => // [...]
// The previous line causes the following compilation error:
// "The argument types of an anonymous function must be fully known. (SLS 8.5)"
}
此扩展在DataSet和DataStream Scala API中引入了一一对应的新方法。 这些方法支持匿名模式匹配功能。
DataSet API
略
DataStream API
略