实时数据的处理方法及系统、即时处理系统

摘要

本申请提供一种实时数据的处理方法及系统、即时处理系统。本申请实施例通过合并节点获得实时处理系统发送的实时数据，进而根据分发策略，在所述至少一个本地节点中，或者合并节点和所述至少一个本地节点中，确定一个节点，以作为处理节点，使得处理节点能够将所述实时数据写入所述即时处理系统中，从而实现了即时处理系统能够针对实时数据进行灵活计算或者查询。

主权项

一种实时数据的处理方法，其特征在于，应用于即时处理系统中，所述即时处理系统包括合并节点和至少一个本地节点，所述方法包括：所述合并节点获得实时处理系统发送的实时数据；所述合并节点根据分发策略，确定一个节点作为处理节点，用以将所述实时数据写入所述即时处理系统中；其中，所述处理节点包括所述合并节点或所述至少一个本地节点中的一个本地节点。