Postponed execution events linking
- 主要语言
- Scala
- 星标
- 667
- 派生
- 155
- 平均合并
- 3 天 6 小时
- 30 天内合并 PR
- 4
描述
When building a global lineage we need to traverse the graph through the boundary of many execution plans, from the affected executions to their predecessors and so forth. For the performance reasons (since an execution plan can be a super node), it's good to avoid looking up the affected executions by sorting and grouping at the boundary of every execution plan, but instead to have them linked directly.
Since the graph is built continuously and asynchronously, at the time of processing a new execution event we don't know if all its predecessors have arrived and processed already. So we cannot build the static links between them immediately. Instead we could do it in time windows, long enough to accommodate any reasonable time delays in the events arrival (once an hour / a day).
贡献指南
这个仓库没有索引到贡献指南
评估
这个 Issue 还没有评估数据。