Data stream processing API