03、Flink实战:DataStream之DataSourceAPI(一)基于Socket的SocketTextStream

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,输入一行,程序就会打印一行

*

*

版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: