Flink从入门到放弃

Flink是一个流批一体处理框架

官网链接：Flink官网

在IDEA上创建一个自己的flink程序

代码如下（示例）：

    org.apache.flink
    flink-streaming-java_2.12
    1.12.7
    


    org.apache.flink
    flink-clients_2.12
    1.12.7




    org.apache.flink
    flink-core
    1.12.7
    

代码如下（示例）：本demo演示数据源为nc数据源

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

DataStreamSource source = env.socketTextStream("your IP", 10086);

System.out.println("********************************************程序开始执行********************************************");

source.print();

env.execute("FirstFlinkApp");

该处使用的url网络请求的数据。

数据输入：

 处理结果：

本篇文章主要是flink初次体验，成功接收数据以及将数据打印在控制台

不知道大家发现没有，打印的数据前面有数字信息，这个信息是跟并行度有关，后面深度探究