Flink入门案例

本篇将通过两个案例来入门Flink流式处理和批处理编程。

准备环境：

Scala 2.12版本

创建一个Maven工程项目

1.1 引入依赖

pom.xml

    
        org.apache.flink
        flink-scala_2.12
        1.10.1
    

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



    
        
        
            net.alchim31.maven
            scala-maven-plugin
            3.4.6
            <