A framework for real time IOT stream processing with a large number of sensor specific data pipelines