flink file source

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

object FlinkDemo04_CommonSource_fromFile {
    case class Flight(avgTicketPrice:String, cancelled:String, carrier:String, dest:String, destAirportID:String, origin:String, originAirportID:String)
    def main(args: Array[String]): Unit = {
        
        //1 创建环境
        val env = StreamExecutionEnvironment.getExecutionEnvironment
        //2 获取DataStream
        val dStream: DataStream[String] = env.readTextFile("I:\projectImplement\dataWareHouse\test-es\data\630data.csv")
        //3 计算
        import org.apache.flink.api.scala._
        dStream.map{
            line=>
            val vals = line.split(",")
            Flight(vals(0),vals(1),vals(2),vals(3),vals(4),vals(5),vals(6))
        }.print()
        //4 执行
        env.execute("stream job")
    }
}