DataSource是程序的数据源输入。
SocketTextStream 可以从Socket中读取字符串数据
import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; public class SocketTextStreamReview { public static void main(String[] args) throws Exception{ // 1.获取flink流计算的运行环境 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // 2.从socketTextStream读取数据 DataStream<String> lines = env.socketTextStream("192.168.***.***", 8888); int parlNum = lines.getParallelism(); System.out.println("The parallelism num of socketTextStream is " + parlNum); // result:1 //3.调用Sink （Sink必须调用） lines.print(); //4.启动流计算 // 这个异常能使用try...catch... 处理,因为程序希望将异常抛给上层flink,flink会根据异常来做相应的重启策略等处理 env.execute("SocketTextStreamReview"); } }socketTextStream是非并行的DataSource，并行度为1.
在linux机器上启动一个socket，输入一行，程序就会打印一行
