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")
  }

}