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
  6.

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

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

注意：对于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项目，它包含两个类：StreamingJob和BatchJob是DataStream和DataSet程序的基本框架程序。的主要方法是程序的入口点，无论是对在-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 API和DataSet API部分。

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

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