我正在寻找 Apache flink 的 hello-world 体验的最简单的示例。
假设我刚刚在一个干净的盒子上安装了 flink,那么为了“让它做某事”我需要做的最低限度是什么。我意识到这很模糊,这里有一些例子。
来自终端的三个 python 示例:
python -c "print('hello world')"
python hello_world.py
python python -c "print(1+1)"
当然,流应用程序要复杂一些,但这里与我之前为 Spark 流所做的类似:
https://spark.apache.org/docs/latest/streaming-programming-guide.html#a-quick-example https://spark.apache.org/docs/latest/streaming-programming-guide.html#a-quick-example
正如您所看到的,这些示例有一些很好的属性:
- 它们是最小的
- 对其他工具/资源的依赖性最小
- 逻辑可以进行简单调整(例如不同的数字或不同的分隔符)
所以我的问题是:
Flink 最简单的 hello world 示例是什么
到目前为止,我发现的是需要编译的包含 50 行代码的示例。
如果由于第 3 点而无法避免这种情况,那么满足第 1 点和第 2 点并使用(仅)默认提供的 jar 或从信誉良好的来源轻松获得的 jar 也可以。
好吧,这个怎么样:
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.fromElements(1, 2, 3, 4, 5)
.map(i -> 2 * i)
.print();
env.execute();
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)