Patent ID: 9361323
Filing Date: 2016-06-07
CPC Classification: G06F

Claim Text:
1. A system, comprising: a computer processor; and logic executable by the computer processor, the logic configured to: receive a declarative specification that includes a plurality of stages, each stage specifying an atomic operation, a data input to the atomic operation, and a data output from the atomic operation, the data input characterized by a data type, the data type being at least one of structured data, semi-structured data, and unstructured data; reduce a complexity of the declarative specification by generating links between at least two of the plurality of stages to create a data integration workflow, the at least two of the plurality of stages in the data integration workflow having data inputs characterized by different data types; compile the data integration workflow to generate computer code for execution on a parallel processing platform, the computer code including instructions configured for: optimize with an optimum number of mappers and reducers the computer code for execution on the parallel processing platform; perform a filter operation via the computer code to retrieve a phone number, the filter operation includes: update a sentiment field in accordance with the positive or negative sentiments extracted from the unstructured data of the message field, wherein the computer code is a MapReduce application.