研究文章
Flink-ER:弹性资源调度策略处理Flink移动流数据
|
输入: |
|
流网络 :G级=
|
|
当前网络流f级 |
|
累积源中每个分区时差家常便饭 |
|
输出: |
|
重标流网络 :G级... |
|
开始 |
|
从流网络构建改善网络 |
|
P级BFSG级f级,G级f级.s,G级f级.T)/∗搜索优化路径∗/ |
|
时最大时差[]) ≥φ安卓P级????? |
|
|f级公元前| ← min{
} |
|
G级扩展FlowG.E.,P级...f级公元前|) |
|
P级BFSG级f级,G级f级.s,G级f级.T) |
|
句尾 |
|
if max时差[]) ≥φ并发 |
|
放大每个运算符的并行性,满足方程标准11) |
|
结束if |
|
G##= taskMigration(运算符) |
|
返回G级... |
|
结束 |
|
