flink读取数据的两种方式

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
object Fli {

  def main(args: Array[String]): Unit = {

    val env = StreamExecutionEnvironment.getExecutionEnvironment
  //本地文件
    val stream = env.readTextFile("C:\Users\Administrator\Desktop\REITS-2022\a.txt")
    stream.print()


    //第二种获取数据源 利用nc-l -p 创造数据
    val stream2 = env.socketTextStream("127.0.0.1",11111)
  
    stream2.print()
    env.execute("hello")
  }

}