International Business Machines Corporation

Marion Lee Blount

Larry Bert Brenner

John Arthur Pershing, Jr

Marc Adam Kaplan

Peter Richard Badovinatz

Tushar Deepak Chandra

Orvalle Theodore Kirby

Ajei Sarat Gopal

Archan Misra

Stephen P Morgan

John Joseph Turek

John Sidney Davis, Ii

Iqbal I Mohomed

Katalin A Rader

Bo Yang

Min Wang

Michael Elton Nidd

Daby Mousse Sow

Maria Rene Ebling

Suzanne K McIntosh

Metin Feridun

Dennis Duane Jurgensen

Axel Tanner

Norman Howard Cohen

John Joseph Edward Turek

Carl D Tait

Robert K Rader

Jonathan Lenchner

David Bruce Lindquist

Hui Lei

Jeffrey Owen Kephart

Paul Christesten Castro

Barron Cornelius Housel, Iii

Lisa Amini

Wim De Pauw

Brent Tzion Hailpern

Chitra Venkatramani

Apratim Purakayastha

Mark F Mergen

Amal A Shaheen-Gouda

Barry Leiba

Wolfgang Segmuller

Steve Mastrianni

Hung-yang Chang

Lee W Hoevel

Richard Allen Floyd

Gene E Trivett

Anthony Cocchi

Marshall Shapiro

Shaheen-Gouda

Robert A Heller

Mechanisms are provided for virtualizing physical sensors and providing sensor data to a requestor using the virtualized physical sensors. The mechanisms obtain sensor data from a plurality of physical sensors and storing the sensor data in a virtual sensor storage system of the data processing system in at least one standardized format. A request from a requestor for a first type of sensor data is received which does not specify a particular physical sensor. A portion of the sensor data stored in the virtual sensor storage system is retrieved in response to receiving the request, the portion of sensor data corresponding to the type of sensor data requested in the request from the requestor. The retrieved portion of the sensor data is returned to the requestor in a format corresponding to a physical sensor configured to provide the requested type of sensor data.

Sensor virtualization through cloud storage and retrieval mechanisms

A sensor is installed in a building management system by determining a sensor type of the sensor from among a plurality of supported sensor types based on information collected by a mobile device of a user; identifying configuration information required by the building management system for the determined sensor type; obtaining the required configuration information from the user using an interface on the mobile device, wherein at least a portion of the interface is generated to accommodate one or more requirements of the building management system with respect to the determined sensor type; and providing the obtained required configuration information to the building management system. The sensor type and unique identifier of the sensor can be automatically determined. Portions of the required configuration information for the determined sensor type can be automatically populated using default information for the determined sensor type.

Sensor installation in a building management system

Techniques are disclosed for determining and validating provenance data in such data stream processing systems. For example, a method for processing data associated with a data stream received by a data stream processing system, wherein the system comprises a plurality of processing elements, comprises the following steps. Input data elements and output data elements associated with at least one processing element of the plurality of processing elements are obtained. One or more intervals are computed for the processing element using data representing observations of associations between inputs elements and output elements of the processing element, wherein, for a given one of the intervals, one or more particular input elements contained within the given interval are determined to have contributed to a particular output element. In another method, intervals are specified, and then validated by comparing the specified intervals against intervals computed based on observations.

Determining and validating provenance data in data stream processing system

Techniques are disclosed for maintaining and processing provenance data in such data stream processing systems. For example, a method for processing data associated with a data stream received by a data stream processing system, wherein the system comprises a plurality of processing elements, comprising the following steps. A portion of data associated with the data stream is maintained. The maintained data comprises inputs to each processing element that contributed to an output of each processing element. In response to an alert generated by one of the processing elements, a scheduler is triggered to determine when a pre-calculation of a prospective query related to the alert should be executed. In response to the scheduler, at least a portion of the maintained data is used to determine a set of data that contributed to the alert such that the alert-contributing set of data can be used to respond to the prospective query upon arrival thereof.

Method and apparatus for maintaining and processing provenance data in data stream processing system

Techniques for deriving a provenance of one or more of a plurality of output data elements generated from a given output port of a PC are provided. At least one dependency function is created that relates the one or more output data elements to a set of one or more input ports of the PC and a corresponding plurality of input data elements. The dependency function comprises an encoding of at least one of one or more temporal filters and one or more sequence filters relating to the plurality of input data elements. The at least one dependency function is stored. A history of stream-level bindings of one or more input streams to one or more input ports of the processing component and one or more output streams from one or more output ports of the processing component is stored. The plurality of input data elements belonging to the one or more input streams and the plurality of output data elements belonging to the one or more output streams are stored. The set of one or more input data elements from the plurality of input data elements are determined that relate to the one or more output data elements in accordance with at least one dependency function and the history of stream-level bindings.

Methods and apparatus for functional model-based data provenance in stream processing environments

Improved discovery techniques are provided. For example, in one aspect of the invention, a technique for making providers of a particular kind of data available to an application program includes the following steps/operations. The technique discovers whether one or more data providers are capable of providing the particular kind of data, wherein a discovered data provider is either a connected data provider or a virtual data provider. When a data provider capable of providing the particular kind of data is discovered and the discovered data provider is a virtual data provider, the technique instantiates the virtual data provider. When a data provider capable of providing the particular kind of data is discovered, the technique makes a data-provider handle for the discovered data provider available to the application program, with a common interface.

Methods and apparatus for discovering data providers satisfying provider queries

Program product for an application programming interface that unifies a plurality of mechanisms into a single framework. The interface includes a mechanism for communicating between members of a process group of related processes, and a mechanism for synchronizing the related processes of the process group. Additionally, the application programming interface may include mechanisms for managing membership of the process group or a processor group of processors, and/or a mechanism for controlling a group state value for the process group.

Program product for an application programming interface unifying multiple mechanisms

There is provided a system and method for representing a data subset of server data. According to the method, a folder definition is generated for the data subset. The generation of the folder definition includes the substeps of identifying portions of the server data to be included in the data subset, generating declarations of value constraints and usage constraints with respect to at least some of the data of the data subset, and generating parameters to be supplied or selected by a user of a client device for further identifying the portions of the server data to be included in the data subset. The declarations are used for enforcing the value constraints and the usage constraints in subsequent renderings of the data subset on a client device. A folder instance is then generated based on the folder definition and parameters provided by a user of a client device or by default. The provided parameters (user provided or default) correspond to the generated parameters. The generation of the folder instance includes the substeps of generating the data subset from the identified portions of the server data and the parameters, and including the declarations of value constraints and usage constraints in the folder instance with the data subset.

System and method for disconnected database access by heterogeneous clients

Methods, systems and computer program products which provide for communicating with a web browser executing on a remote/mobile processing system which is temporarily and intermittently connected to a second computer by storing in a persistent request queue at the second computer, a request from the web browser to a server application accessible to the second computer. Also disclosed are methods, systems and computer program products which allow for operation and management of asynchronous operations of a web browser where the operations are carried out by a server-side intercept module.

Server-side asynchronous form management

A barrier synchronization system in a distributed computing environment. A group of members, including a plurality of related processes executing on one or more processors of the distributed computing environment, is provided a protocol having a dynamic number of synchronization phases. The protocol is voted on by one or more members of the group to determine how the protocol should proceed for the group of members. The protocol may complete successfully, continue to another synchronization phase or be rejected. The group of members determines how many synchronization phases the protocol is to include.

System for barrier synchronization wherein members dynamic voting

An application programming interface that unifies a plurality of mechanisms into a single framework. The interface includes a mechanism for communicating between members of a process group of related processes, and a mechanism for synchronizing the related processes of the process group. Additionally, the application programming interface may include mechanisms for managing membership of the process group or a processor group of processors, and/or a mechanism for controlling a group state value for the process group.

Application programming interface unifying multiple mechanisms

A barrier synchronization program product in a distributed computing environment. A group of members, including a plurality of related processes executing on one or more processors of the distributed computing environment, is provided a protocol having a dynamic number of synchronization phases. The protocol is voted on by one or more members of the group to determine how the protocol should proceed for the group of members. The protocol may complete successfully, continue to another synchronization phase or be rejected. The group of members determines how many synchronization phases the protocol is to include.

Program product to effect barrier synchronization in a distributed

Growing community of inventors

Mahopac, NY, United States of America

Marion Lee Blount