Pipeline processing framework