ANALYZING A PARALLEL DATA STREAM USING A SLIDING FREQUENT PATTERN TREE
First Claim
Patent Images
1. A non-transitory computer-readable medium storing instructions executable by a processing resource to cause a computer to:
- identify input channels for a plurality of sliding frequent pattern (FP) tree task instances of a parallel data stream;
create a sliding FP tree for each of the plurality of sliding FP tree task instances using input tuples from the identified input channels belonging to a first parallel sliding window boundary; and
analyze patterns of the parallel data stream first parallel sliding window boundary using the plurality of sliding FP trees.
8 Assignments
0 Petitions
Accused Products
Abstract
A technique for analyzing a parallel data stream using a sliding FP tree can include create a sliding FP tree using input tuples belonging to a parallel sliding window boundary and analyze patterns of the parallel data stream in the parallel sliding window boundary.
14 Citations
15 Claims
-
1. A non-transitory computer-readable medium storing instructions executable by a processing resource to cause a computer to:
-
identify input channels for a plurality of sliding frequent pattern (FP) tree task instances of a parallel data stream; create a sliding FP tree for each of the plurality of sliding FP tree task instances using input tuples from the identified input channels belonging to a first parallel sliding window boundary; and analyze patterns of the parallel data stream first parallel sliding window boundary using the plurality of sliding FP trees. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A method for analyzing a parallel data stream, including:
-
ordering a plurality of item-sets associated with a parallel data stream based on a frequency of each of the plurality of item-sets; incrementally creating a sliding frequent pattern (FP) tree over a plurality of parallel sliding windows using the order of the plurality of item-sets; and analyzing patterns of the parallel data stream using the sliding FP tree in each parallel sliding window in response to an input tuple for each input channel of the parallel data stream reaching a boundary of the corresponding parallel sliding window. - View Dependent Claims (8, 9, 10, 11)
-
-
12. A system for analyzing a parallel data stream, comprising:
-
a processing resource; and a memory resource communicatively coupled to the processing resource containing instructions executable by the processing resource to implement a number of engines including; a parallel window engine to define a plurality of parallel sliding window boundaries; an item-set order engine to organize input tuples using a defined frequency baser order of a plurality of item-sets; an input tuple engine to store input tuples belonging to a future parallel sliding window; a sliding FP tree engine to incrementally create a sliding FP tree for each of a plurality of sliding FP tree task instances using the defined frequency based order, wherein each increment to one of the sliding FP trees includes; add item-sets to the sliding FP tree identified in a current parallel sliding window boundary among the plurality of parallel sliding window boundaries; and subtract item-sets from the sliding FP tree identified in a previous parallel sliding window boundary among the plurality of sliding window boundaries; and an analyze engine to identify frequent item-sets in the parallel data stream using the plurality of sliding FP trees. - View Dependent Claims (13, 14, 15)
-
Specification