implemented DataStream