Stream processing framework