流处理单元的分配方法及装置

摘要

本发明公开了一种流处理单元的分配方法及装置，属于通信技术领域。方法包括：获取各个计算节点上的流处理组件的并行度及资源使用率，并根据并行度确定流处理单元的数量；生成待分配的流处理单元，并将流处理组件的资源使用率确定为对应的流处理单元的资源使用率；根据流处理组件所在计算节点的处理能力及分配的流处理单元的资源使用率将待分配的流处理单元分配到对应的计算节点中。本发明通过根据各个流处理组件所在计算节点的处理能力及各个待分配的流处理单元的资源使用率将各个待分配的流处理单元分配到对应的计算节点中，使得计算节点的处理能力满足分配给该计算节点的流处理单元的资源使用率，从而提高了分布式流处理系统处理流数据的效率。

主权项

一种流处理单元的分配方法，其特征在于，所述方法包括：获取各个计算节点上的各个流处理组件的并行度及资源使用率，所述并行度用于表示流处理组件包括的流处理单元的数量；根据所述流处理组件中任一流处理组件的并行度确定所述任一流处理组件包括的流处理单元的数量；生成与所述流处理组件相对应的至少一个待分配的流处理单元，并将所述任一流处理组件的资源使用率确定为所述任一流处理组件相对应的任一流处理单元的资源使用率；根据各个流处理组件所在计算节点的处理能力及各个待分配的流处理单元的资源使用率将所述各个待分配的流处理单元分配到对应的计算节点中。