flink基础学习案例之读取文本-日常记录

flink基础学习案例之读取文本-日常记录

1、用idea工具创建一个简单的maven项目

2、修改pom.xml文件增加flink的jar依赖

    
    
        org.apache.flink
        flink-java
        1.10.1
    

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

3、在resources目录下建立文件 sensor.txt

sensor_1,15477180200,10.6
sensor_1,15477180201,15.4
sensor_1,15477180202,6.7
sensor_1,15477180203,38.1

 4、创建SourceTest2_File.java文件

package com.atguigu.apitest.source;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class SourceTest2_File {
    public static void main(String[] args) throws Exception {

        // 执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 从文件读取数据
        DataStream dataStream = env.readTextFile("D:\java_code\FlinkTutorial\src\main\resources\sensor.txt");

        // 打印输出
        dataStream.print();

        env.execute();
    }
}

 5、输出结果

 

来自视频中手工编写