本文共 482 字，大约阅读时间需要 1 分钟。

object DataStreamSourceApp {  def main(args: Array[String]): Unit = {    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment    socketFunction(env)    env.execute("DataStreamSourceApp")  }  def socketFunction(env: StreamExecutionEnvironment): Unit ={    val data = env.socketTextStream("192.168.101.128",9999)    data.print().setParallelism(1)  }}

To run the example program, start the input stream with netcat first from a terminal:

nc -lk 9999

转载地址：https://mapengsen.blog.csdn.net/article/details/108900674 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！