流数据处理方法和装置

摘要

本发明涉及一种流数据处理方法和装置。该流数据处理方法主要包括：实时接收各业务产生的流数据，对所述流数据进行统计并将统计得到的所述各业务对应的统计数据存储到内存中；在需要清理所述内存的情况下，在对第一统计周期内的最后一条流数据统计完成之后，将所述内存中存储的所述第一统计周期内的统计数据清除。本发明在内存中分配适当容量的存储空间用于对流数据的处理，按照不同的统计周期存储各统计周期对应的统计数据，并在某一统计周期内的最后一条流数据统计完成之后，将所述内存中存储的该统计周期内的统计数据清除，提高流数据处理的速度和效率，保证了流数据处理的准确性。

主权项

一种流数据处理方法，其特征在于，包括：实时接收各业务产生的流数据，对所述流数据进行统计并将统计得到的所述各业务对应的统计数据存储到内存中；其中，在所述内存中，按照不同的统计周期存储各统计周期对应的统计数据；在需要清理所述内存的情况下，在对第一统计周期内的最后一条流数据统计完成之后，将所述内存中存储的所述第一统计周期内的统计数据清除。