Flink_BasicTypelnfo与java原生数据类型转换

Flink通过实现 BasicTypelnfo数据类型,能够支持任意Java原生基本类型(装箱)
或 String类型,例如 Integer、 String、 Double等
如以下代码所示,通过从给定的元素集中创建 DataStream数据集。

//创建Int类型的数据集
val instream: DataStream[Int]= env. fromElements(3, 1,2,1,5)

//创建 string类型的数据集
val datastream: DataStream[ String] env fromElements(“hello”,”fink”)

Flink实现另外一种 TypeInfomation是 Basic Array TypeInfo,对应的是Java基本类
型数组(装箱)或 String对象的数组,如下代码通过使用Aray数组和List集合创建
DataStream数据集。

//通过从数组中创建数据集

val dataStream: DataStream[ Int]= env. fromCollection(Array (3, 1, 2, 1, 5))

//通过List集合创建数据集

val dataStream: DataStream[Int] =env. fromCollection(List(3, l,2,1, 5))