一种分布式数据的处理方法和系统

摘要

本申请实施例提供了一种分布式数据的处理方法和系统，其中，所述的方法包括：碎片节点接收客户端针对某一个表上传的数据；碎片节点将所述数据存储至所述表对应的存储目录中；当存储成功时，碎片节点将所述数据发送至相连的每个流式计算节点进行流式计算，使得数据一次落地就可以同时被离线计算节点和实时的流式计算节点共享使用，不必依赖消息中间件，降低了系统的复杂度，相比消息队列减少了一次落地的过程，减少了存储成本、出错的概率以及处理的延迟。

主权项

一种分布式数据的处理方法，其特征在于，包括：碎片节点接收客户端针对某一个表上传的数据；碎片节点将所述数据存储至所述表对应的存储目录中；当存储成功时，碎片节点将所述数据发送至相连的每个流式计算节点进行流式计算。