Pattern matching across multiple input data streams
First Claim
Patent Images
1. A computer-implemented method, comprising:
- receiving, by a computer system configured with computer-executable instructions, a plurality of input data streams comprising at least a first input data stream and a second input data stream, the first input data stream having a first associated schema, the second input data stream having a second associated schema, and the first associated schema being different from the second associated schema;
generating, by the computer system, a first dynamic data type for the first input data stream;
generating, by the computer system, a second dynamic data type for the second input data stream;
generating, by the computer system, a homogenous schema representing the first input data stream and the second input data stream based at least in part on the first dynamic data type and the second dynamic data type;
combining, by the computer system, the first input data stream and the second input data stream to generate a combined data stream based at least in part on the homogeneous schema; and
processing, by the computer system, a continuous query over the combined data stream to detect a pattern.
1 Assignment
0 Petitions
Accused Products
Abstract
A method for detecting patterns across multiple input data streams related to one or more applications is disclosed. The method includes receiving multiple input data streams and generating one or more dynamic data types for one or more attributes of the input data streams. In some embodiments, the method may include combining the input data streams to generate a combined input data stream based on the dynamic data types and processing a continuous query over the combined data stream to detect a pattern.
-
Citations
20 Claims
-
1. A computer-implemented method, comprising:
-
receiving, by a computer system configured with computer-executable instructions, a plurality of input data streams comprising at least a first input data stream and a second input data stream, the first input data stream having a first associated schema, the second input data stream having a second associated schema, and the first associated schema being different from the second associated schema; generating, by the computer system, a first dynamic data type for the first input data stream; generating, by the computer system, a second dynamic data type for the second input data stream; generating, by the computer system, a homogenous schema representing the first input data stream and the second input data stream based at least in part on the first dynamic data type and the second dynamic data type; combining, by the computer system, the first input data stream and the second input data stream to generate a combined data stream based at least in part on the homogeneous schema; and processing, by the computer system, a continuous query over the combined data stream to detect a pattern. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. A system, comprising:
-
a memory storing a plurality of instructions; and a processor configured to access the memory, wherein the processor is further configured to execute the plurality of instructions to at least; receive a continuous query identifying a first input data stream and a second input data stream, the first input data stream having a first associated schema, the second input data stream having a second associated schema, and the first associated schema being different from the second associated schema; identify a first dynamic data type for a first attribute of the first input data stream; identify a second dynamic data type for a second attribute of the second input data stream; generate a homogenous schema representing the first input data stream and the second input data stream based at least in part on the first dynamic data type and the second dynamic data type; generate a combined data stream based at least in part on the homogenous schema; and execute the continuous query over the combined data stream to detect a pattern. - View Dependent Claims (10, 11, 12, 13, 14, 15)
-
-
16. One or more non-transitory computer-readable media storing computer executable instructions executable by one or more processors, the computer-executable instructions comprising:
-
instructions that cause the one or more processors to receive a plurality of input data streams comprising at least a first input data stream and a second input data stream, the first input data stream having a first associated schema, the second input data stream having a second associated schema, and the first associated schema being different from the second associated schema; instructions that cause the one or more processors to generate a first dynamic data type for the first input data stream; instructions that cause the one or more processors to generate a second dynamic data type for the second input data stream; instructions that cause the one or more processors to generate a homogenous schema representing the first input data stream and the second input data stream based at least in part on the first dynamic data type and the second dynamic data type; instructions that cause the one or more processors to combine the first input data stream and the second input data stream to generate a combined data stream based at least in part on the homogenous schema; and instructions that cause the one or more processors to process a continuous query over the combined data stream to detect a pattern. - View Dependent Claims (17, 18, 19, 20)
-
Specification