返回介绍

Storm 兼容性示例

发布于 2025-05-02 18:19:17 字数 682 浏览 0 评论 0 收藏

您可以在 Maven 模块中找到更多示例 flink-storm-examples 。有关不同版本的 WordCount,请参阅 README.md 。要运行示例,您需要组装正确的 jar 文件。 flink-storm-examples-1.7-SNAPSHOT.jarno / not 作业执行有效的 jar 文件(这仅仅是一个标准的 Maven 神器)。

有嵌入式喷口和螺栓,即例如罐 WordCount-SpoutSource.jarWordCount-BoltTokenizer.jar 分别。比较 pom.xml 看两个罐子是如何构建的。此外,整个 Storm 拓扑( WordCount-StormTopology.jar )有一个例子。

您可以通过运行这些示例中的每一个 bin/flink run <jarname>.jar 。每个 jar 的清单文件中都包含正确的入口点类。

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。