ELASTIC AUTO-PARALLELIZATION FOR STREAM PROCESSING APPLICATIONS BASED ON A MEASURED THROUGHTPUT AND CONGESTION

摘要

A method for adjusting a data parallel region of a stream processing application includes measuring congestion of each parallel channel of the data parallel region, measuring a total throughput of all the parallel channels, and adjusting the number of parallel channels based on the current measured congestion and throughput.