流数据处理方法

本申请提供了一种流数据处理方法，应用于数据处理器，该方法包括：获取来自于分布式流处理集群的流数据；流数据包括至少一个数据分片；通过远程直接内存访问，发送流数据至图形处理器的第一存储单元；基于预设的地址映射关系，发送第一提示信息至图形处理器的第二存储单元；第一提示信息表征至少一个第一数据分片已发送完成；获取来自于图形处理器的第二提示信息；第二提示信息表征第一数据分片中的至少一个第二数据分片已校验完成；基于第一数据分片和第二数据分片分别对应的数量，确定第一存储单元的占用率；基于占用率，调节流数据的获取速率。