Java项目模板

从几个简单的步骤开始使用Flink Java程序。

要求

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

创建项目

使用以下命令之一 create a project:

  1.  $ mvn archetype:generate                               \
  2.       -DarchetypeGroupId=org.apache.flink              \
  3.       -DarchetypeArtifactId=flink-quickstart-java      \
  4.       -DarchetypeVersion=1.7.1

这允许您将新创建的项目命名为。它会交互式地询问groupId、artifactId和包名。

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

检查项目

您的工作目录中将有一个新目录。如果您使用了 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 程序的基本框架程序。main 方法是程序的入口点，用于ide内测试/执行和适当的部署。

我们建议您将这个项目导入您的IDE中进行开发和测试。IntelliJ IDEA支持Maven项目的开箱即用。如果您使用Eclipse， m2e plugin允许 import Maven projects。默认情况下，一些Eclipse包包含该插件，另一些则需要手动安装。

Mac OS X users 注意:Java的默认JVM堆大小对于Flink来说可能太小了。你必须手动增加它。在Eclipse中，选择Run Configurations -> Arguments ;并写入VM Arguments框:-Xmx800m。在IntelliJ IDEA中，建议通过Help | Edit Custom VM Options 菜单来改变JVM选项。有关详细信息，请参见this article。

构建项目

如果您想build/package your project，请转到您的项目目录并运行‘mvn clean package’ 命令。您将找到一个JAR文件，其中包含您的应用程序，以及您可能作为依赖项添加到应用程序中的连接器和库:target/<artifact-id>-<version>.jar。

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

下一个步骤

写您的应用程序!

如果您正在编写流应用程序，并且正在寻找编写内容的灵感，那么可以参考Stream Processing application Tutorial。

如果您正在编写批处理应用程序，并且正在寻找编写的灵感，那么可以参考Batch Application Examples。

有关API的完整概述，请查看 DataStream API 和DataSet API小节。

Here您可以了解如何在本地集群上运行IDE之外的应用程序。

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