主权项 |
1. A system comprising:
a data stream and class definition receive module configured to receive a data stream having a defined number of data blocks and a class definition for the data stream; a data stream partition module configured to partition said received data stream into a set of data blocks, wherein each data block comprises N data segments; a data block processing module configured to process each data block in parallel, and for each data block, compute the following:
a first integer value based on whether each segment value of the data block forms part of the class definition;a second integer value based on a number of consecutive data segment values that form part of the class definition starting from a left-hand side of the data block;a third integer value based on a maximum number of consecutive data segment values in the data block that form part of the class definition; anda fourth integer value based on a number of consecutive data segment values that form part of the class definition starting from a right-hand side of the data block; and a data block integration module configured to aggregate the first integer value, the second integer value, the third integer value, and the fourth integer value for each data block in a sequential and associative manner to determine, for the received data stream, a maximum number of consecutive data segment values in the received data stream that form part of the class definition. |