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

摘要

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.

主权项

1. An apparatus for managing data streams from sensor devices received by a mobile client device, the apparatus comprising:
a memory configured to store received data from the sensor devices; and a processor configured to: identify a plurality of data streams each corresponding to a respective sensor device, each of the plurality of data streams being receivable by the mobile client device; specify an order for which each of the plurality of data streams is to be processed by an event processing module of the client device; receive at least one of the plurality of data streams in the specified order; determine at least a partial result of a query predicate using data from the received at least one of the plurality of data streams; and if the query predicate is partially resolved, then dynamically modify some property of a process by which a remaining selected set of the plurality of data streams and data are retrieved by the event proceeding module.