开发者社区> 问答> 正文

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

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

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

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

展开
收起
flink小助手 2018-12-10 13:45:37 1641 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

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

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

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

    2019-07-17 23:19:14
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Instagram Direct 高效可靠的数据端到端传输 立即下载
Flink中的两类新型状态存储 立即下载
金融异构报文处理和分发 立即下载