Online-adaptive data stream processing