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

Claim 14:
15. One or more non-transitory machine-readable information storage mediums comprising one or more instructions which when executed by one or more hardware processors cause:
providing, the plurality of data streams as an input from one or more sources;
analyzing, via the one or more hardware processors, the plurality of data streams to generate an intermediate output, wherein the intermediate output comprises metadata;
receiving a request by an integration engine implemented via the one or more hardware processors 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;

checking, via the one or more hardware processors, a load of each analytical engines among a plurality of analytical engines implemented via the one or more hardware processors, by a workload manager implemented via the one or more hardware processors;
determining, via the one or more hardware processors, one or more analytical engines out of the plurality of analytical engines, depending on the checked load;
assigning, via the one or more hardware processors, 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;
performing, via the one or more hardware processors, one of a downscaling or an upscaling 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;
determining, via the one or more hardware processors, 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
triggering, via the one or more hardware processors, 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.