International Business Machines Corporation

Telcordia Technologies, Inc.

University of Texas System

Archan Misra

Paul Christesten Castro

Maria Rene Ebling

Norman Howard Cohen

Daby Mousse Sow

Marion Lee Blount

John Sidney Davis, Ii

Min Wang

Arup Acharya

Dipanjan Chakraborty

William Francis Jerome

Inseok Hwang

Prathima Agrawal

Subir Das

Xiping Wang

Benjamin Falchuk

Nilanjan Banerjee

Koustuv Dasgupta

Rajeev Shorey

Iqbal Ismail Mohomed

Sajal K Das

Wen Hu

Atanu Roy Chowdhury

Han Qi

Edith H Stern

Charles P Wright

Amit Anil Nanavati

Chatschik Bisdikian

Ashutosh Dutta

Lisa Amini

Wim De Pauw

Chitra Venkatramani

Apratim Purakayastha

Wolfgang Segmuller

Barry Leiba

Iqbal I Mohomed

Charles W Wright

Anthony McAuley

Jinwon Lee

Suraj Kumar Jaiswal

Ya-Ti Peng

Iqbal c/o Ibm Uk Ltd Ipl Mohomed

Improved descriptive query techniques are provided. More particularly, techniques are provided for specifying and processing descriptive queries for data providers grouped into provider kinds with hierarchical containment relationships. The query may include arbitrary boolean combinations of arbitrary tests on the values of attributes of the data providers.

Methods and apparatus for specifying and processing descriptive queries for data sources

Mobile wireless devices may receive data streams from multiple remote sensors. The sensors may have limited power supplies and memory capacity. Aspects of the invention use statistical characteristics of the sensor data streams and the cost of acquiring a single element of each stream to determine what sequence the sensors should send their data streams in. The cost of acquiring the data may be modified dynamically, depending on parameters such as block size. Additional factors, such as a sensor's buffer capacity, may limit the amount of stream elements that may be cached and affect the sensors' stream transmit sequence. The evaluation order may be dynamically modified using an event processing engine, to reflect both changing statistics of underlying sensor stream tuples and time-varying acquisition costs associated with individual streams. This helps to increase in the operational lifetime of the sensors and associated monitoring applications.

Optimizing evaluation patterns and data acquisition for stream analytics in resource-constrained wireless environments

Methods and apparatus of adaptively transmitting data are provided. Data for transmission from one or more incoming data streams is determined in accordance with at least one characteristic of a respective one of the one or more data streams and at least one context external of the data stream. A compression technique for the data and a transmission strategy for the data are modified in accordance with the data determined for transmission.

Methods and apparatus for efficient and adaptive transmission of data in data collection networks

Techniques for selecting a new compression technique or altering the currently instantiated compression technique employed over a data stream in data collection system are provided. At least one change to at least one external contextual condition is detected. One or more modifications to a defined compression technique is generated, either independently or in conjunction with one or more modifications to the event processing operators that operate on the data stream and whose output provides the values that are compressed by the defined compression technique, in response to the at least one change to the at least one external contextual condition. The defined compression technique of the at least one client device is altered in accordance with the one or more modifications to form a modified compression technique through which the unmodified or processed data stream will be compressed before being sent to the server.

Adapting compression techniques over data based on context

A method for continually controlling the collective behavior of a set of computing devices in a distributed data processing system. A gateway node disseminates a specification request comprising a set of parameters to a set of computing devices. The gateway node may be unaware of the number and identity of individual computing devices. Each computing node receiving the request determines whether its attributes satisfy the predicates expressed in the specification request. If so, the node processes the parameters in the specification request and modifies its own behavior based on the values in the parameters of the specification request. Subsequently, the gateway node may also observe the quality of information (QoI) values communicated from the set of computing devices. The gateway node iteratively modifies the parameters disseminated in subsequent specification requests based on a divergence between a computed quality of information value and a desired quality of information value.

Adaptively modifying the observed collective behavior of individual sensor nodes based on broadcasting of parameters

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 localized adaptation of client devices based on correlation or learning at a remote server. For example, a method for modifying a behavior of a client device in a data collection system, wherein the client device collects data and transmits data to a server, includes the following steps. The client device transmits data to the server. The server uses at least a portion of the data received from the client device to generate information that represents a modification to a behavior of the client device. The server device transmits the generated information to the client device. The client device subsequently alters the behavior of the client device based on the information received from the server.

Method and apparatus for localized adaptation of client devices based on correlation or learning at remote server

Methods and systems are provided for associating contextual data with communication sessions, in particular in technical help desk scenarios. A context logger service running on a central server or on an individual computing device is used to create a log of application specific, often ephemeral, contextual data for a plurality of applications running one or more systems that are in communication with the context logger service across one or more networks. When a communication session between an initiating entity and a receiving entity to request assistance regarding a subject application running on one of the systems is initiated, and if the communication session is deemed to be a candidate for the automatic association of such context data, at least a portion of the application specific contextual data contained in the log is associated with the communication session and delivered to the receiving entity. The receiving entity uses the associated application specific contextual data to provide the requested assistance, or otherwise improve the operations at the receiving entity.

Method for intelligent and automated transmission of local context in converged signaling

Techniques are disclosed for generating and managing presentities in accordance with a virtual presence server. By way of example, a method for requesting information from at least one server comprises the following steps. A client request, which expresses a request that can not be satisfied by a single existing presentity, is obtained at an intermediate server, wherein the intermediate server operates as a virtual presence server. The virtual presence server (i.e., intermediate server) creates a set of software objects for a virtual presentity, the set of objects embodying logic to combine presence information from one or more of existing presentities and external information sources, in accordance with at least one existing presence server. The virtual presence server creates an association between the request of the client and the created virtual presentity that allows the presence information to be propagated back to the client.

Virtual presence server

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 supporting a presence virtualization query are provided. The techniques include receiving a virtual query from a client, the virtual query specified in terms of a membership set of members, wherein the membership set comprises a list of presentity uniform resource identifiers (URIs) and a separate transformation function, defined over a set of presence documents of the members in the membership set, redirecting the query to a destination virtual presentity URI whose presence state comprises an aggregation of the presence documents of the list of URIs in the membership set and a corresponding query element (QE) object that manages subscriptions for the URI, adding the client as a watcher for the destination virtual presentity URI, and applying transformation logic specified by the watcher client and notifying a corresponding client of a resulting output.

Programmable presence virtualization

A method is provided for performing a classification. The method includes ranking a plurality of features of a training set according to how closely they are correlated to their corresponding classifications, extracting a plurality of features of from input data, selecting a subset of the plurality of features such that a computational resource cost of the subset is less than a predefined computational resource maximum and a degree of utility achieved by a classification of the subset by a selected classifier is optimized and exceeds a predefined utility minimum, predicting one of the features of the sensor data that is not selected for the subset of features from a predefined number of past samples of the feature and adding the predicted feature to the subset of features, and classifying, by a processor, using the selected classifier and the resulting subset of features.

Methods and systems for selecting features and using the selected features to perform a classification

Growing community of inventors

Irvington, NY, United States of America

Archan Misra