Method for processing sensor data within a particle stream by a KStore
View Patent ↗A method for processing a particle stream in a KStore having a sensor level and a first level above the sensor level, including receiving a particle to provide a received particle and first determining a current K node to determine a partial sequence location. The method also includes second determining a match in accordance with the received particle and the current K node to provide a match determination and processing the current K node based upon the match determination. A new node is created if the second determining is negative. A current K node is set to the new node. A node count is incremented and a delimiter particle type of the received particle is determined. A match is determined between the delimiter and a Result node of an asCase node of the current K node to provide a delimiter match determination.
1. A method for processing a particle stream in a KStore interlocking tree datastore having a sensor level of elemental root nodes and a first level above said sensor level, said particle stream having a plurality of input particles, comprising:
receiving at least one particle within said particle stream to provide a received particle;
first determining a current K node to determine a partial sequence location;
second determining a match in accordance with said received particle and said current K node to provide a match determination; and
processing said current K node based upon said match determination;
wherein the KStore interlocking trees datastore comprising a plurality of nodes, and a K node of the plurality of nodes comprises a Case pointer and a Result pointer, said Case pointer and said Result pointer pointing to two nodes from which the K node is formed, the K node also comprising pointers to an asCase array and an asResult array, the asCase array comprising pointers to nodes whose Case pointers point to said K node and wherein the asResult array comprises pointers to nodes whose Result pointers point to said K node.
2. The method for processing a particle stream in a KStore of claim 1 , further comprising creating a new node if said second determining is negative.
3. The method for processing a particle stream in a KStore of claim 2 , further comprising setting a current K node to said new node.
4. The method for processing a particle stream in a KStore of claim 2 , further comprising incrementing a node count.
5. The method for processing a particle stream in a KStore of claim 1 , further comprising determining a particle type of said received particle.
6. The method for processing a particle stream in a KStore of claim 5 , further comprising determining that said particle type is a delimiter.
7. The method for processing a particle stream in a KStore of claim 6 , further comprising determining a match between said delimiter and a Result node of an asCase node of said current K node to provide a delimiter match determination.
8. The method for processing a particle stream in a KStore of claim 7 , further comprising creating an end product node if said delimiter match determination is negative.
9. The method for processing a particle stream in a KStore of claim 8 , further comprising setting said current K node to a sequence beginning location.
10. The method for processing a particle stream in a KStore of claim 9 , wherein said sequence beginning location comprises a beginning of thought location.
11. The method for processing a particle stream in a KStore of claim 7 , further comprising setting said current K node to beginning of sequence if said delimiter match determination is positive.
12. The method for processing a particle stream in a KStore of claim 7 , further comprising incrementing a node count.
13. The method for processing a particle stream in a KStore of claim 5 , further comprising determining that said particle type is a sensor data particle.
14. The method for processing a particle stream in a KStore of claim 13 , further comprising determining a match between said sensor data particle and a Result node of an asCase node of said current K node to provide a sensor data match determination.
15. The method for processing a particle stream in a KStore of claim 14 , further comprising creating new subcomponent node if said sensor data match determination is negative.
16. The method for processing a particle stream in a KStore of claim 15 , further comprising setting said current K node to said new subcomponent node.
17. The method for processing a particle stream in a KStore of claim 14 , further comprising setting said current K node to matched subcomponent node if said delimiter match determination is positive.
18. The method for processing a particle stream in a KStore of claim 14 , further comprising incrementing a node count.
19. The method for processing a particle stream in a KStore of claim 1 , wherein said K Store includes a state data structure for storing a current K node to indicate a partial sequence location.
20. The method for processing a particle stream in a KStore of claim 19 , wherein said received particle is a reset state structure indicator.
21. The method for processing a particle stream in a KStore of claim 20 , wherein said reset state structure indicator is a null particle.
22. The method for processing a particle stream in a KStore of claim 20 , wherein said current K node within said state structure is reset to sequence begin indicator.
23. The method for processing a particle stream in a KStore of claim 22 , wherein said current K node within said state structure is reset to a begin of sequence node.
24. The method for processing a particle stream in a KStore of claim 19 , wherein said first determining comprises accessing said state data structure.
25. The method for processing a particle stream in a KStore of claim 19 , further comprising determining whether said received particle is included in said state data structure.
26. The method for processing a particle stream in a KStore of claim 24 , further comprising determining said current K node in accordance with said state data structure.
27. The method for processing a particle stream in a KStore of claim 19 , wherein said state data structure comprises a delimiter list.
28. The method for processing a particle stream in a KStore of claim 19 , wherein said state data structure comprises a list of sensors.
29. The method for processing a particle stream in a KStore of claim 28 , wherein said state data structure comprises a delimiter list.
30. The method for processing a particle stream in a KStore of claim 1 , further comprising providing a list of particles.
31. The method for processing a particle stream in a KStore of claim 30 , wherein said second determining comprises determining whether said received particle is included in said a list of particles.
32. The method for processing a particle stream in a KStore of claim 31 , further comprising performing no further operations with said received particle if a said received particle does not match any particle on said list of particles.
33. The method for processing a particle stream in a KStore of claim 1 , wherein said current K node has an adjacent K node that is adjacent to said current K node and said second determining comprises locating said adjacent node in accordance with an asCase list of said current K node to provide a located asCase node.
34. The method for processing a particle stream in a KStore of claim 33 , wherein said asCase list includes a plurality of asCase nodes further comprising locating a plurality of adjacent nodes in accordance with said asCase list.
35. The method for processing a particle stream in a KStore of claim 34 , wherein said match determination comprises determining a Result node of said located asCase node to provide a located Result node.
36. The method for processing a particle stream in a KStore of claim 35 , wherein said second determining comprises comparing said located Result node with said received particle.
37. The method for processing a particle stream in a KStore of claim 36 , further comprising creating a new node if said second determining is negative.
38. The method for processing a particle stream in a KStore of claim 37 , further comprising setting a current K node to said new node.
39. The method for processing a particle stream in a KStore of claim 36 , further comprising performing no further operations if said second determining is negative and if a learn functionality of said KStore is disabled and a Result node of said located asCase node does not match said received particle.
40. The method for processing a particle stream in a KStore of claim 36 , further comprising incrementing a node count.
41. The method for processing a particle stream in a KStore of claim 36 , further comprising setting a current K node to said matched node.