Flink Project Template For Java

Posted 2021-04-13 北辰文阁

当前浏览器不支持播放音乐或语音，请在微信或其他浏览器中播放

准备

 

1. Maven 3.0.4（或者更高）

2. Java 8.x

 

创建项目

 

使用下面命令之一创建项目：

1. 使用Maven 原型创建：

 mvn archetype:generate                               \
      -DarchetypeGroupId=org.apache.flink              \
      -DarchetypeArtifactId=flink-quickstart-java     \
      -DarchetypeVersion=1.5.4

1. 运行快速启动脚本：

curl https://flink.apache.org/q/quickstart.sh | bash -s1.5.4

 

检验项目

 

执行以上命令之一便会在你工作目录下生成新的目录，如果你执行的是快速启动脚本方式，那么目录名为 quickstart，其他情况，目录名是你设置的 artifactId：

$ treequickstart/
quickstart/
├── pom.xml
└── src
    └── main
        ├── java
        │   └── org
        │       └── myorg
        │           └── quickstart
        │               ├── BatchJob.java
        │               └── StreamingJob.java
        └── resources
            └── log4j.properties

 

样本项目是一个Maven工程，包括两个类：StreamingJob 和 BatchJob ，是数据流和数据集项目程序中的基本骨架。主方法是整个程序的入口，两个在IDE中都可以 testing/execution，以及进行恰当的项目布施。

 

我们推荐你通过你的IDE导入项目来开发和测试。IntelliJ IDEA 支持Maven项目。如果你使用Eclipse，那么m2e插件允许你导入Maven项目。一些版本的Eclipse已经默认绑定了该插件，其他的你需要自己去安装。

 

一个针对Mac系统用户的小笔记：

默认的Java JVM堆空间对于Flink来说太小了。你需要手动提高它。

在Eclipse里，你可以在Configurations -> Arguments中的VM属性里填写：-Xmx800m.

在IntellJ IDEA里推荐方式 Help | Edit Custom Vm Options菜单修改。这篇文章有详细介绍。

构建项目

 

如果你想要构建或者打包你的项目，推荐你进入项目目录下执行‘mvn clean package’执行成功后你将会看到JAR 包文件，其中包括你的应用、附加连接器和应用的依赖库： target/<artifact-id>-<version>.jar

 

Note：如果你使用不同于StreamingJob的类作为主类入口，我们推荐你在pom.xml文件中修改mailClass。这样的话，Flink就能够不用额外指定主类运行MainClass

 

下个步骤

 

写你的应用！

如果你正在写一个流处理应用，你寻找写它的启发文章，你可以看看流处理应用指南。

如果你正在写一个批处理应用，你寻找写它的启发文章，你可以看看批处理应用指南。

完整的API文档，你可以查看数据流API和数据集合API选项。

这里有你能够找到如何在IDE下运行本地集群的方法。

如果你遇到问题了，可以使用邮件方式询问，我们会提供帮助