摘要:
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.
摘要:
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.
摘要:
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.
摘要:
A method, system, and computer program for dynamically setting up collaborative associations between a group of users, computing resources, and/or communication devices, where the constituents of the collaborative association are chosen based on a variety of contextual criteria. The dynamic collaboration enabler component determines the explicit identities of the parties that should be a part of the collaboration. The group of individual entities involved in the collaboration can change dynamically during the lifetime of the collaboration, based on appropriate changes in the contextual data. Such contextual data refers to both state variables associated with the collaboration software or infrastructure itself, or to the state of entities external to the collaboration. The duration of the collaborative association is specified either explicitly or through a set of context related conditions. The dynamic context enabler can detect when the set of termination conditions is satisfied and then automatically remove the collaborative association.
摘要:
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.
摘要:
A method, system, and computer program for dynamically setting up collaborative associations between a group of users, computing resources, and/or communication devices, where the constituents of the collaborative association are chosen based on a variety of contextual criteria. The dynamic collaboration enabler component determines the explicit identities of the parties that should be a part of the collaboration. The group of individual entities involved in the collaboration can change dynamically during the lifetime of the collaboration, based on appropriate changes in the contextual data. Such contextual data refers to both state variables associated with the collaboration software or infrastructure itself, or to the state of entities external to the collaboration. The duration of the collaborative association is specified either explicitly or through a set of context related conditions. The dynamic context enabler can detect when the set of termination conditions is satisfied and then automatically remove the collaborative association.
摘要:
A method and system for reliable multicasting on a communication network includes sending Request-to-Send (RTS) signals from a sender node of the network to the receiver nodes, the RTS signals include a set of identifiers corresponding to the receiver nodes. The Clear-to-Send (CTS) signals and Acknowledgment (ACK) signals are sent from the receiver nodes according to an ordering function of the set of identifiers.
摘要:
A method and system for reliable multicasting on a communication network includes sending Request-to-Send (RTS) signals from a sender node of the network to the receiver nodes, the RTS signals include a set of identifiers corresponding to the receiver nodes. The Clear-to-Send (CTS) signals and Acknowledgment (ACK) signals are sent from the receiver nodes according to an ordering function of the set of identifiers.
摘要:
Methods and systems are provided for facilitating intra-domain mobility. A first network or domain includes a home agent or SIP proxy of a mobile node. A second network includes two or more subnetworks and at least one mobility agent (MA). Each subnetwork includes an associated subnet agent. To communicate, the mobile node first registers with a subnet agent, receives a local care-of-address and a global care-of-address, and then registers with an MA. The mobile node may then provide the global care-of-address to the home agent. The local care-of-address may enable communication with the mobile node without determining a specific route to the mobile node. The global care-of-address received from the subnet agent may include the address of the MA. Accordingly, the mobile node may transition from any of the subnetworks to another subnetwork without communicating to the home agent information about the transition and without communicating to the MA information about a security association between the mobile node and the home agent.
摘要:
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.