stream processing pipeline prototype