In recent years, a new class of applications has come to the forefront { p- marily due to the advancement in our ability to collect data from multitudes of devices, and process them e ciently. These - plications need to process data continuously (and as long as data is available) from one or more sources.