Java项目模板

只需几个简单的步骤即可开始使用Flink Java程序。

要求

唯一的要求是使用Maven 3.0.4(或更高版本)和Java 8.x安装。

创建项目

使用以下命令之一创建项目

  1. $ mvn archetype:generate \
  2. -DarchetypeGroupId=org.apache.flink \
  3. -DarchetypeArtifactId=flink-quickstart-java \
  4. -DarchetypeCatalog=https://repository.apache.org/content/repositories/snapshots/ \
  5. -DarchetypeVersion=1.7-SNAPSHOT

这允许您命名新创建的项目它将以交互方式询问您groupId,artifactId和包名称。

  1. $ curl https://flink.apache.org/q/quickstart-SNAPSHOT.sh | bash -s 1.7-SNAPSHOT

注意:对于Maven 3.0或更高版本,不再可以通过命令行指定存储库(-DarchetypeCatalog)。如果要使用SNAPSHOT存储库,则需要向settings.xml添加存储库条目。有关此更改的详细信息,请参阅Maven官方文档

检查项目

您的工作目录中将有一个新目录。如果您使用了curl方法,则会调用该目录quickstart否则,它的名称为artifactId

  1. $ tree quickstart/
  2. quickstart/
  3. ├── pom.xml
  4. └── src
  5. └── main
  6. ├── java
  7. └── org
  8. └── myorg
  9. └── quickstart
  10. ├── BatchJob.java
  11. └── StreamingJob.java
  12. └── resources
  13. └── log4j.properties

示例项目是一个Maven项目,它包含两个类:StreamingJobBatchJobDataStreamDataSet程序的基本框架程序。主要方法是程序的入口点,无论是对在-IDE测试/执行并作适当的部署。

我们建议您将此项目导入IDE以进行开发和测试。IntelliJ IDEA支持开箱即用的Maven项目。如果您使用Eclipse,则m2e插件允许导入Maven项目某些Eclipse包默认包含该插件,其他包需要您手动安装它。

Mac OS X用户注意事项:对于Flink,Java默认JVM堆可能太小。你必须手动增加它。在Eclipse中,选择Run Configurations -> Arguments并写入VM Arguments框:-Xmx800m在IntelliJ IDEA中,推荐的方法是从Help | Edit Custom VM Options菜单中更改JVM选项有关详细信息,请参阅此文

构建项目

如果要构建/打包项目,请转到项目目录并运行' mvn clean package'命令。您将找到一个包含您的应用程序的JAR文件,以及您可能已作为依赖项添加到应用程序的连接器和库:target/<artifact-id>-<version>.jar

注意:如果您使用与StreamingJob不同的类作为应用程序的主类/入口点,我们建议您相应地更改文件中mainClass设置pom.xml这样,Flink可以从JAR文件运行时间应用程序,而无需另外指定主类。

下一步

写你的申请!

如果您正在编写流处理应用程序并且正在寻找灵感来写什么,请查看流处理应用程序教程

如果您正在编写批处理应用程序,并且正在寻找要编写的内容,请查看批处理应用程序示例

有关API的完整概述,请查看DataStream APIDataSet API部分。

在这里,您可以了解如何在本地群集上的IDE外部运行应用程序。

如果您有任何问题,请在我们的邮件列表中查询我们很乐意提供帮助。