Atl*_*tle 9 apache-flink hazelcast-jet
更具体地说,Hazelcast Jet解决了Flink无法解决的问题(同样好),反之亦然？
Mar*_*nik 12
注意:我属于Hazelcast Jet的核心工程团队.
我想说Hazelcast Jet的主要优势不在于提供全新的计算模型,而在于为Hazelcast提供与基于DAG的分布式计算领域相同的便利性.
如果您当前在群集中运行Java应用程序,则添加Jet将非常简单:添加Maven依赖项并编写一行代码以在本地成员上启动Jet实例.实例将自我发现以形成自己的群集,您现在可以将作业提交给它.
如果你想要一个专用的分布式计算集群,你将使用Jet作为单一依赖项创建一个简单的项目,并在集群中运行它,然后再从一个代码行再从外部连接到它.
毋庸置疑,Jet使用Hazelcast IMap或IList作为数据源非常方便.Jet集群可以直接托管Hazelcast结构; 然后,您将从数据位置中受益,并获得没有网络流量的数据.另一方面,数据源的选择完全不受约束,并且存在专用于实现快速,任意分区的自定义数据源的公共API.
在0.3版本中,Jet为您提供了灵活而强大的DAG模型,您可以精确控制计算的性能关键方面,以及java.util.stream适合分布式计算细节的熟悉API 形式的高级便利层(lambda)序列化和其他问题).
在1.0里程碑的路线图中,是对无限流处理的关注的一流支持,例如时间窗口,一致的快照以及对群集拓扑中的更改的弹性.
| 归档时间： |
|
| 查看次数： |
1409 次 |
| 最近记录： |