Patent ID: 11954630
Assignee: TATA CONSULTANCY SERVICES LIMITED
Field: Digital communication (Electrical engineering)
Classification: CPC G  H | IPC G

Claim 7:
8. A system for analyzing a plurality of data streams in real time, the system comprises:
an input/output interface configured to provide the plurality of data streams as an input from one or more sources;
one or more hardware processors; and
a memory in communication with the one or more hardware processors, wherein the one or more first hardware processors are configured to execute programmed instructions stored in the memory, to:
analyze the plurality of data streams to generate an intermediate output, wherein the intermediate output comprises metadata;
receive, a request by an integration engine for analyzing one or more data streams out of the plurality of data streams, wherein the integration engine is configured to perform one or more of the following actions depending on the received request:
starting data analysis to analyze the data stream, wherein the start analysis receives a list of data streams, a list of analysis to be performed and details of a callback to be invoked for match propagation as input,
determining and providing the status of a previously started data analysis session, wherein a list of session ID's are provided as input, and
stopping data analysis to stop the data analysis session, wherein the list of session ID's are provided as input;

check a load of each analytical engines among a plurality of analytical engines by a workload manager;
determine one or more analytical engines out of the plurality of analytical engines, depending on the checked load;
assign the request for analyzing to the determined one or more analytical engines, wherein the one or more analytical engines is configured to generate an output data stream at an output processing rate;
perform one of a downscale or an upscale the output processing rate of the one or more analytical engines if the output processing rate is more than or less than a predefined value, respectively, to get scaled data stream;
determine a set of business rules that are required to be checked in the scaled data stream, wherein the set of business rules is determined based on a comparison performed by the meta data with a predefined set of conditions; and
trigger a call back by performing a lookup on the determined set of business rules to intimate the integration engine to analyze the plurality of data streams.