一种行集数据的处理方法、装置及数据处理系统

摘要

本发明适用于数据处理技术领域，提供了一种行集数据的处理方法、装置及数据处理系统。所述方法包括以下步骤：将待处理的行集数据传入起始任务节点的输入缓冲区；从所述输入缓冲区中逐行取出数据进行处理，将处理完的数据传输至中转缓冲区；当存在下一个中继任务节点时，从当前中转缓冲区中逐行取出数据进行处理，将处理完的数据传输至下一个中转缓冲区，以此类推；当不存在下一个中继任务节点时，从当前中转缓冲区中逐行取出数据进行处理，将处理完的数据传输至终止任务节点的输出缓冲区；将终止任务节点输出缓冲区的数据输出。本发明提高了数据处理的响应速度、且处理数据时无需占用更多内存。

主权项

一种行集数据的处理方法，其特征在于，所述方法包括以下步骤：将待处理的行集数据传入起始任务节点的输入缓冲区；从所述输入缓冲区中逐行取出数据进行处理，将处理完的数据传输至中转缓冲区；当存在下一个中继任务节点时，从当前中转缓冲区中逐行取出数据进行处理，将处理完的数据传输至下一个中转缓冲区，以此类推；当不存在下一个中继任务节点时，从当前中转缓冲区中逐行取出数据进行处理，将处理完的数据传输至终止任务节点的输出缓冲区；将终止任务节点输出缓冲区的数据输出。