Implemented basic structure of streaming pipleline