flink source fromCollection source

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}
import org.apache.flink.api.scala._

object FlinkDemo03_CommonSource_fromEle {
    
    case class Student(name: String, age: Int)
    
    def main(args: Array[String]): Unit = {
        //1 創建環境
        val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
        //2 讀取數據
        val ds: DataStream[Student] = env.fromCollection(List(Student("jack", 20), Student("rose", 18)))
        //3 計算
        ds.print()
        
        //4 執行
        env.execute()
    }
}