用 Apache Flink 创建带状态的流式应用

Sun Feb 16, 2020

首先创建项目框架

在终端中执行如下命令:

curl https://flink.apache.org/q/quickstart-scala-SNAPSHOT.sh | bash -s 1.10.0

此例子中使用了 flink-table 依赖, 我们在 pom 文件中加入它:

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table</artifactId>
            <version>${flink.version}</version>
            <type>pom</type>
            <scope>provided</scope>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-common -->
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-common</artifactId>
            <version>${flink.version}</version>
            <scope>provided</scope>
        </dependency>