Embodiments of the present application relate to a distributed data stream processing method, a distributed data stream processing device, a computer program product for processing a raw data stream and a distributed data stream processing system. Methods, apparatus and systems are disclosed. An example apparatus may be used to determine the attention demands on a vehicle operator.