如何在Apache Flink核心中构建项目

Question

我是Apache Flink的初学者，找不到任何关于扩展Flink核心的信息。我想从简单的开始：在一个测试类中构建。我应该在flink中的某个位置将该类保存为jar文件吗？

Answer 1

我最近开始用ApacheFlink开发小程序，所以我也遇到了同样的问题。我建议您使用maven，因为它将允许链接您需要的所有依赖项，并轻松构建自己的类。

您需要首先安装maven，然后使用以下命令创建Flink maven项目：

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

之后可以将您的类添加到src/main/java/[GroupId]../并使用进行编译

mvn package

然后，要运行新创建的程序，您可以执行以下命令：

mvn exec:java -Dexec.mainClass="Package.YourClass" -Dexec.args="YOUR PROGRAM ARGUMENTS"

如果你愿意的话，互联网上也有关于如何使用IDE运行maven的教程。