用于分布式数据处理的并行决策系统及其方法

摘要

本发明公开了一种用于分布式数据处理的并行决策系统和方法。所述系统包括：初始逻辑节点生成组件、逻辑节点遍历组件、预定构型代价计算组件以及并行决策组件。所述初始逻辑节点生成组件接收用户输入的任务配置数据生成用于所述分布式数据处理系统的初始逻辑节点拓扑图。所述逻辑节点遍历组件遍历所述初始逻辑节点拓扑图以获取所述初始逻辑节点拓扑图中的预定构型。所述预定构型代价计算组件计算每种预定构型的传输代价和计算代价和。所述预定构型变换组件根据预定构型的结果缩减初始逻辑节点和连接边以及合并初始逻辑节点和连接边，从而获得缩减初始逻辑节点后的变换结果逻辑节点拓扑图，以便降低并行决策的解空间。所述并行决策组件针对变换结果逻辑节点拓扑图通过局部贪心策略获取总最小代价的并行方案。