开发者社区> 问答> 正文

数据工匠如何流式传输分类帐调度工作

flink小助手 2018-12-10 13:45:37 325

我已阅读白皮书但关于Data Artisans Streaming Ledger,但发现它只包含如何使用框架的高级概述。

我正在寻找更深入的解释或研究论文,解释如何在内部完成多键事务调度,以及如何使用逻辑时钟来保证一致性。

有谁知道我在哪里可以找到更多细节?

调度 流计算
分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:19:14

    这就是我到目前为止所发现的1-事件需要是确定性的,这意味着它所写的值仅取决于它读取的值它不允许读取挂钟时间或生成随机数... 2-来排队a要执行的事务,您需要定义将要读取和写入的完整密钥集,不允许触摸的密钥动态地依赖于事件执行期间读取的值。

    因此,一旦事务排队,所有分区将以相对于其他事务的相同顺序处理它(订单事务在队列中),并且可以静态地确定负责该事件触摸的一些键的所有工作者。

    一旦所有这些工作人员到达队列中的此事件位置,他们首先执行所有读取操作并将读取的值发送给将执行至少一次写入的所有工作者。然后,所有负责至少一次写入的工作程序在本地准备写入,并报告事件是否应该回滚到所有其他节点。如果所有节点同意提交所有工作者提交本地准备写入。

    0 0
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题