International Business Machines Corporation

Other

Massachusetts Institute of Technology

Rodric Rabbah

Perry S Cheng

Stephen Fink

David Francis Bacon

Joshua S Auerbach

Martin J Hirzel

Mandana Vaziri

Philippe Suter

Vinod Muthusamy

Sunil K Shukla

Olivier L J Tardieu

Aleksander A Slominski

Manu Sridharan

Cosmin A Radoi

Olivier Tardieu

Anant Agarwal

Nicholas Matthew Mitchell

Hoang Anh Le

Jeremias Werner

Perry Sze-Din Cheng

Emery D Berger

Charles M Curtsinger

Daniel W Barowy

Shripad Nagarkar

At a cloud platform, a class of feed is received for an external feed corresponding to an information source, as are an instruction corresponding to a create operation for the external feed, and a dictionary input corresponding to parameters expected by the information source. The external feed produces a corresponding class of events. At the cloud platform, a handler is selected based on the received class of feed and the received create operation; the input dictionary is transferred to the handler; and the handler generates a unique destination to receive events for the class of events. The handler on the cloud platform generates a unique request to the information source to generate events of the class of feed to the unique destination and sends the request to the information source. Events generated from the information source responsive to the unique request are received at the unique destination.

Managing external feeds in an event-based computing system

A processor may receive a query from a user. The query may include one or more portions. The processor may identify a primary function. The processor may determine to segment the primary function into two or more subsidiary functions. The processor may process a first portion of the query with a first subsidiary function. The processor may display a processed outcome of the query to the user.

Serverless composition of functions into applications

Output is obtained from a remote computer function on a first set of arguments. Responsive to determining that the output exhibits an error, a fixer routine, other than a retry, is applied to the arguments to produce new arguments. Output is obtained from the remote computer function on the new arguments. In a case where the output from the remote computer function on the new arguments is acceptable, the output from the remote computer function on the new arguments is used as a corresponding output from the remote computer function on the first set of arguments. These steps can advantageously be carried out without modifying program code of the remote computer function and without access to the program code of the remote computer function; for example, by a wrapper which black-box wraps the remote computer function.

Automatic error fixes for high-availability applications

A method, system and computer readable program product are disclosed for compiling a spreadsheet to execute stream processing in a computing system. In an embodiment, the method comprises extracting a function from the spreadsheet, said function supporting data windows and stream partitioning in the computing system; and identifying input cells of the spreadsheet for holding input values for the function, and identifying output cells of the spreadsheet for holding output values of the function. In embodiments of the invention, a data stream is partitioned into a plurality of data stream partitions, and the extracted function is applied to the stream partitions in parallel. In embodiments of the invention, the extracted function is applied to the data stream partitions in series. The windows may be time based windows, and may be count based windows, and the windows may have variable sizes.

Spreadsheet compiler for stream processing

A method, system and computer readable program product are disclosed for encoding a function in a spreadsheet program to execute stream processing on a computing system. In embodiments of the invention, the method comprises encoding one or more formulas in one or more cells of the spreadsheet program, each of the formulas supporting data windows and stream partitioning; designating a first group of cells of the spreadsheet program as input cells for holding input values for the one or more formulas; and designating a second group of cells of the spreadsheet program as output cells for holding output values of the one or more formulas. In embodiments of the invention, the stream partitioning includes partitioning a defined stream of data into a plurality of data stream partitions, and the one or more formulas are encoded to operate on the plurality of data stream partitions.

Encoding a spreadsheet program for stream processing

An action sequence including a plurality of actions and a corresponding input dictionary are obtained. A first container, running an image for a first one of the actions implemented in a first programming language, is instantiated, and the image is executed on the input dictionary to obtain a first action result; the input dictionary is then updated with the first action result to obtain an updated input dictionary. A second container, running an image for a second one of the actions implemented in a second programming language, different than the first programming language, is instantiated, and the image is executed on the updated input dictionary to obtain a second action result; the updated input dictionary is further updated with the second action result to obtain a further updated input dictionary. The input dictionaries are independent of the programming languages.

Language-independent program composition using containers

Converting data transformations entered in a spreadsheet program into a circuit representation of those transformations. The circuit representation can run independently of the spreadsheet program to transform input data into output data. In some cases the circuit representation is in the form of hardware, accepts and/or produces data streams, and/or the circuit and/or output data or data streams can be shared among multiple users and/or subscribers. Where data streams are processed, the transformations may include well-specified timing semantics, supporting operations that involve rate-based rate manipulation, value-based rate manipulation, and/or access to past cell values.

Stream-enabled spreadsheet as a circuit

The present disclosure relates generally to the field of automatic conversion of sequential array-based programs to parallel MapReduce programs. In various examples, automatic conversion of sequential array-based programs to parallel MapReduce programs may be implemented in the form of systems, methods and/or algorithms.

Automatic conversion of sequential array-based programs to parallel map-reduce programs

Compile-time recognition of graph structure where graph has arbitrary connectivity and is constructed using recursive computations is provided. In one aspect, the graph structure recognized at compile time may be duplicated at runtime and can then operate on runtime values not known at compile time.

Extracting stream graph structure in a computer language by pre-executing a deterministic subset

Extraction of functional semantics and isolated dataflow from imperative object oriented languages, in one aspect, may include identifying one or more methods and/or classes associated with one or more of a plurality of property labels in a computer code written in object oriented language to extract functional and isolation characteristics in the computer code. The plurality of property labels supported by one or more checking rules, are used to verify that the one or more methods and/or classes identified with the plurality of property labels have isolation characteristics. An object oriented language compiler is provided for supplying the plurality of property labels and checking rules. The object oriented language compiler further may include capability to transform methods into compute tasks and connect the compute tasks so as to create a dataflow graph.

Extraction of functional semantics and isolated dataflow from imperative object oriented languages

A communication stack for software-hardware co-execution on heterogeneous computing systems with processors and reconfigurable logic, in one aspect, may comprise a crossbar operable to connect hardware user code and functioning as a platform independent communication layer. A physical interface interfaces to the reconfigurable logic. A physical interface bridge is connected to the cross and the physical interface. The physical interface bridge connects the crossbar and the physical interface via a platform specific translation layer specific to the reconfigurable logic. The crossbar, the physical interface, and the physical interface bridge may be instantiated in response to the hardware user code being generated, the crossbar instantiated with associated parameters comprising one or more routes and associated data widths. The hardware user code is assigned a unique virtual route in the crossbar.

Growing community of inventors

Yonkers, NY, United States of America

Rodric Rabbah