Method for processing sensor data within a particle stream by a KStore

• US 20070220070A1
• Filed: 03/20/2006
• Published: 09/20/2007
• Est. Priority Date: 03/20/2006
• Status: Active Grant

• Current Assignee: Unisys Corporation
• Original Assignee: Unisys Corporation
• Inventors: Mazzagatti, Jane
• Granted Patent: US 7,734,571 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2246 Trees, e.g. B+trees
• CPC Class Codes: G06F 16/322 Trees
• CPC Class Codes: Y10S 707/99943 Generating database or data structure, e.g. via user interface

Abstract

A method for processing a partide 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.

Claims

1. A method for processing a particle stream in a KStore 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.

2. The method for processing a partide 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 partide 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.